• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Socks5BytestreamManager类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager的典型用法代码示例。如果您正苦于以下问题:Java Socks5BytestreamManager类的具体用法?Java Socks5BytestreamManager怎么用?Java Socks5BytestreamManager使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



Socks5BytestreamManager类属于org.jivesoftware.smackx.bytestreams.socks5包,在下文中一共展示了Socks5BytestreamManager类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: sendFile

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
/**
 * Send file to provided JID via a SOCKS5 Bytestream session (XEP-0065).
 * 
 * @param file
 * @param jid
 * @throws SmackException
 * @throws InterruptedException
 * @throws IOException
 * @throws XMPPException
 */
public void sendFile(byte[] file, String jid)
		throws XMPPException, IOException, InterruptedException, SmackException {
	String jidFinal = getFullJid(jid);
	jidFinal += "/receiver";
	Socks5BytestreamManager bytestreamManager = Socks5BytestreamManager.getBytestreamManager(connection);
	OutputStream outputStream = null;
	try {
		Socks5BytestreamSession session = bytestreamManager.establishSession(jidFinal);
		outputStream = session.getOutputStream();
		outputStream.write(file);
		outputStream.flush();
	} finally {
		if (outputStream != null) {
			try {
				outputStream.close();
			} catch (IOException e) {
				logger.error(e.getMessage(), e);
			}
		}
	}
}
 
开发者ID:Pardus-LiderAhenk,项目名称:lider,代码行数:32,代码来源:XMPPClientImpl.java


示例2: setServiceEnabled

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
/**
 * Enable the Jabber services related to file transfer on the particular
 * connection.
 *
 * @param connection The connection on which to enable or disable the services.
 * @param isEnabled  True to enable, false to disable.
 */
public static void setServiceEnabled(final Connection connection,
        final boolean isEnabled) {
    ServiceDiscoveryManager manager = ServiceDiscoveryManager
            .getInstanceFor(connection);

    List<String> namespaces = new ArrayList<String>();
    namespaces.addAll(Arrays.asList(NAMESPACE));
    namespaces.add(InBandBytestreamManager.NAMESPACE);
    if (!IBB_ONLY) {
        namespaces.add(Socks5BytestreamManager.NAMESPACE);
    }

    for (String namespace : namespaces) {
        if (isEnabled) {
            if (!manager.includesFeature(namespace)) {
                manager.addFeature(namespace);
            }
        } else {
            manager.removeFeature(namespace);
        }
    }
    
}
 
开发者ID:ice-coffee,项目名称:EIM,代码行数:31,代码来源:FileTransferNegotiator.java


示例3: isServiceEnabled

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
/**
 * Checks to see if all file transfer related services are enabled on the
 * connection.
 *
 * @param connection The connection to check
 * @return True if all related services are enabled, false if they are not.
 */
public static boolean isServiceEnabled(final Connection connection) {
    ServiceDiscoveryManager manager = ServiceDiscoveryManager
            .getInstanceFor(connection);

    List<String> namespaces = new ArrayList<String>();
    namespaces.addAll(Arrays.asList(NAMESPACE));
    namespaces.add(InBandBytestreamManager.NAMESPACE);
    if (!IBB_ONLY) {
        namespaces.add(Socks5BytestreamManager.NAMESPACE);
    }

    for (String namespace : namespaces) {
        if (!manager.includesFeature(namespace)) {
            return false;
        }
    }
    return true;
}
 
开发者ID:ice-coffee,项目名称:EIM,代码行数:26,代码来源:FileTransferNegotiator.java


示例4: setServiceEnabled

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
/**
 * Enable the Jabber services related to file transfer on the particular
 * connection.
 * 
 * @param connection
 *            The connection on which to enable or disable the services.
 * @param isEnabled
 *            True to enable, false to disable.
 */
public static void setServiceEnabled(final Connection connection,
		final boolean isEnabled) {
	ServiceDiscoveryManager manager = ServiceDiscoveryManager
			.getInstanceFor(connection);

	List<String> namespaces = new ArrayList<String>();
	namespaces.addAll(Arrays.asList(NAMESPACE));
	namespaces.add(InBandBytestreamManager.NAMESPACE);
	if (!IBB_ONLY) {
		namespaces.add(Socks5BytestreamManager.NAMESPACE);
	}

	for (String namespace : namespaces) {
		if (isEnabled) {
			if (!manager.includesFeature(namespace)) {
				manager.addFeature(namespace);
			}
		} else {
			manager.removeFeature(namespace);
		}
	}

}
 
开发者ID:ikantech,项目名称:xmppsupport_v2,代码行数:33,代码来源:FileTransferNegotiator.java


示例5: isServiceEnabled

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
/**
 * Checks to see if all file transfer related services are enabled on the
 * connection.
 * 
 * @param connection
 *            The connection to check
 * @return True if all related services are enabled, false if they are not.
 */
public static boolean isServiceEnabled(final Connection connection) {
	ServiceDiscoveryManager manager = ServiceDiscoveryManager
			.getInstanceFor(connection);

	List<String> namespaces = new ArrayList<String>();
	namespaces.addAll(Arrays.asList(NAMESPACE));
	namespaces.add(InBandBytestreamManager.NAMESPACE);
	if (!IBB_ONLY) {
		namespaces.add(Socks5BytestreamManager.NAMESPACE);
	}

	for (String namespace : namespaces) {
		if (!manager.includesFeature(namespace)) {
			return false;
		}
	}
	return true;
}
 
开发者ID:ikantech,项目名称:xmppsupport_v2,代码行数:27,代码来源:FileTransferNegotiator.java


示例6: testInitializationSocks5FeaturesAndListenerOnStartup

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
/**
 * Socks5 feature should be added to the service discovery on Smack startup.
 * 
 * @throws XMPPException should not happen
 */
public void testInitializationSocks5FeaturesAndListenerOnStartup() throws XMPPException {
    XMPPConnection connection = getConnection(0);

    assertTrue(ServiceDiscoveryManager.getInstanceFor(connection).includesFeature(
                    Socks5BytestreamManager.NAMESPACE));

}
 
开发者ID:TTalkIM,项目名称:Smack,代码行数:13,代码来源:Socks5ByteStreamTest.java


示例7: getSupportedProtocols

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
/**
 * Returns a collection of the supported transfer protocols.
 *
 * @return Returns a collection of the supported transfer protocols.
 */
public static Collection<String> getSupportedProtocols() {
    List<String> protocols = new ArrayList<String>();
    protocols.add(InBandBytestreamManager.NAMESPACE);
    if (!IBB_ONLY) {
        protocols.add(Socks5BytestreamManager.NAMESPACE);
    }
    return Collections.unmodifiableList(protocols);
}
 
开发者ID:ice-coffee,项目名称:EIM,代码行数:14,代码来源:FileTransferNegotiator.java


示例8: getNegotiator

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
private StreamNegotiator getNegotiator(final FormField field)
        throws XMPPException {
    String variable;
    boolean isByteStream = false;
    boolean isIBB = false;
    for (Iterator<FormField.Option> it = field.getOptions(); it.hasNext();) {
        variable = it.next().getValue();
        if (variable.equals(Socks5BytestreamManager.NAMESPACE) && !IBB_ONLY) {
            isByteStream = true;
        }
        else if (variable.equals(InBandBytestreamManager.NAMESPACE)) {
            isIBB = true;
        }
    }

    if (!isByteStream && !isIBB) {
        XMPPError error = new XMPPError(XMPPError.Condition.bad_request,
                "No acceptable transfer mechanism");
        throw new XMPPException(error.getMessage(), error);
    }

    if (isByteStream && isIBB && field.getType().equals(FormField.TYPE_LIST_MULTI)) {
        return new FaultTolerantNegotiator(connection,
                byteStreamTransferManager,
                inbandTransferManager);
    }
    else if (isByteStream) {
        return byteStreamTransferManager;
    }
    else {
        return inbandTransferManager;
    }
}
 
开发者ID:ice-coffee,项目名称:EIM,代码行数:34,代码来源:FileTransferNegotiator.java


示例9: getOutgoingNegotiator

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
private StreamNegotiator getOutgoingNegotiator(final FormField field)
        throws XMPPException {
    String variable;
    boolean isByteStream = false;
    boolean isIBB = false;
    for (Iterator<String> it = field.getValues(); it.hasNext();) {
        variable = it.next();
        if (variable.equals(Socks5BytestreamManager.NAMESPACE) && !IBB_ONLY) {
            isByteStream = true;
        }
        else if (variable.equals(InBandBytestreamManager.NAMESPACE)) {
            isIBB = true;
        }
    }

    if (!isByteStream && !isIBB) {
        XMPPError error = new XMPPError(XMPPError.Condition.bad_request,
                "No acceptable transfer mechanism");
        throw new XMPPException(error.getMessage(), error);
    }

    if (isByteStream && isIBB) {
        return new FaultTolerantNegotiator(connection,
                byteStreamTransferManager, inbandTransferManager);
    }
    else if (isByteStream) {
        return byteStreamTransferManager;
    }
    else {
        return inbandTransferManager;
    }
}
 
开发者ID:ice-coffee,项目名称:EIM,代码行数:33,代码来源:FileTransferNegotiator.java


示例10: createDefaultInitiationForm

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
private DataForm createDefaultInitiationForm() {
    DataForm form = new DataForm(Form.TYPE_FORM);
    FormField field = new FormField(STREAM_DATA_FIELD_NAME);
    field.setType(FormField.TYPE_LIST_MULTI);
    if (!IBB_ONLY) {
        field.addOption(new FormField.Option(Socks5BytestreamManager.NAMESPACE));
    }
    field.addOption(new FormField.Option(InBandBytestreamManager.NAMESPACE));
    form.addField(field);
    return form;
}
 
开发者ID:ice-coffee,项目名称:EIM,代码行数:12,代码来源:FileTransferNegotiator.java


示例11: getNegotiator

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
private StreamNegotiator getNegotiator(final FormField field)
        throws XMPPException {
    String variable;
    boolean isByteStream = false;
    boolean isIBB = false;
    for (Iterator<FormField.Option> it = field.getOptions(); it.hasNext();) {
        variable = it.next().getValue();
        if (variable.equals(Socks5BytestreamManager.NAMESPACE) && !IBB_ONLY) {
            isByteStream = true;
        }
        else if (variable.equals(InBandBytestreamManager.NAMESPACE)) {
            isIBB = true;
        }
    }

    if (!isByteStream && !isIBB) {
        XMPPError error = new XMPPError(XMPPError.Condition.bad_request,
                "No acceptable transfer mechanism");
        throw new XMPPException(error.getMessage(), error);
    }

   //if (isByteStream && isIBB && field.getType().equals(FormField.TYPE_LIST_MULTI)) {
    if (isByteStream && isIBB) { 
        return new FaultTolerantNegotiator(connection,
                byteStreamTransferManager,
                inbandTransferManager);
    }
    else if (isByteStream) {
        return byteStreamTransferManager;
    }
    else {
        return inbandTransferManager;
    }
}
 
开发者ID:CJC-ivotten,项目名称:androidPN-client.,代码行数:35,代码来源:FileTransferNegotiator.java


示例12: createDefaultInitiationForm

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
private DataForm createDefaultInitiationForm() {
    DataForm form = new DataForm(Form.TYPE_FORM);
    FormField field = new FormField(STREAM_DATA_FIELD_NAME);
    field.setType(FormField.TYPE_LIST_SINGLE);
    if (!IBB_ONLY) {
        field.addOption(new FormField.Option(Socks5BytestreamManager.NAMESPACE));
    }
    field.addOption(new FormField.Option(InBandBytestreamManager.NAMESPACE));
    form.addField(field);
    return form;
}
 
开发者ID:CJC-ivotten,项目名称:androidPN-client.,代码行数:12,代码来源:FileTransferNegotiator.java


示例13: getSupportedProtocols

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
/**
 * Returns a collection of the supported transfer protocols.
 * 
 * @return Returns a collection of the supported transfer protocols.
 */
public static Collection<String> getSupportedProtocols() {
	List<String> protocols = new ArrayList<String>();
	protocols.add(InBandBytestreamManager.NAMESPACE);
	if (!IBB_ONLY) {
		protocols.add(Socks5BytestreamManager.NAMESPACE);
	}
	return Collections.unmodifiableList(protocols);
}
 
开发者ID:ikantech,项目名称:xmppsupport_v2,代码行数:14,代码来源:FileTransferNegotiator.java


示例14: getNegotiator

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
private StreamNegotiator getNegotiator(final FormField field)
		throws XMPPException {
	String variable;
	boolean isByteStream = false;
	boolean isIBB = false;
	for (Iterator<FormField.Option> it = field.getOptions(); it.hasNext();) {
		variable = it.next().getValue();
		if (variable.equals(Socks5BytestreamManager.NAMESPACE) && !IBB_ONLY) {
			isByteStream = true;
		} else if (variable.equals(InBandBytestreamManager.NAMESPACE)) {
			isIBB = true;
		}
	}

	if (!isByteStream && !isIBB) {
		XMPPError error = new XMPPError(XMPPError.Condition.bad_request,
				"No acceptable transfer mechanism");
		throw new XMPPException(error.getMessage(), error);
	}

	// if (isByteStream && isIBB &&
	// field.getType().equals(FormField.TYPE_LIST_MULTI)) {
	if (isByteStream && isIBB) {
		return new FaultTolerantNegotiator(connection,
				byteStreamTransferManager, inbandTransferManager);
	} else if (isByteStream) {
		return byteStreamTransferManager;
	} else {
		return inbandTransferManager;
	}
}
 
开发者ID:ikantech,项目名称:xmppsupport_v2,代码行数:32,代码来源:FileTransferNegotiator.java


示例15: getOutgoingNegotiator

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
private StreamNegotiator getOutgoingNegotiator(final FormField field)
		throws XMPPException {
	String variable;
	boolean isByteStream = false;
	boolean isIBB = false;
	for (Iterator<String> it = field.getValues(); it.hasNext();) {
		variable = it.next();
		if (variable.equals(Socks5BytestreamManager.NAMESPACE) && !IBB_ONLY) {
			isByteStream = true;
		} else if (variable.equals(InBandBytestreamManager.NAMESPACE)) {
			isIBB = true;
		}
	}

	if (!isByteStream && !isIBB) {
		XMPPError error = new XMPPError(XMPPError.Condition.bad_request,
				"No acceptable transfer mechanism");
		throw new XMPPException(error.getMessage(), error);
	}

	if (isByteStream || isIBB) {
		return new FaultTolerantNegotiator(connection,
				byteStreamTransferManager, inbandTransferManager);
	} else if (isByteStream) {
		return byteStreamTransferManager;
	} else {
		return inbandTransferManager;
	}
}
 
开发者ID:ikantech,项目名称:xmppsupport_v2,代码行数:30,代码来源:FileTransferNegotiator.java


示例16: createDefaultInitiationForm

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
private DataForm createDefaultInitiationForm() {
	DataForm form = new DataForm(Form.TYPE_FORM);
	FormField field = new FormField(STREAM_DATA_FIELD_NAME);
	field.setType(FormField.TYPE_LIST_SINGLE);
	if (!IBB_ONLY) {
		field.addOption(new FormField.Option(
				Socks5BytestreamManager.NAMESPACE));
	}
	field.addOption(new FormField.Option(InBandBytestreamManager.NAMESPACE));
	form.addField(field);
	return form;
}
 
开发者ID:ikantech,项目名称:xmppsupport_v2,代码行数:13,代码来源:FileTransferNegotiator.java


示例17: newConnection

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
@Override
public void newConnection(XMPPConnection connection) {
	// disable streamhost prioritization
	Socks5BytestreamManager s5bsm = Socks5BytestreamManager.getBytestreamManager(connection);
	s5bsm.setProxyPrioritizationEnabled(false);
	sFileTransferManager = FileTransferManager.getInstanceFor(connection);
	sFileTransferManager.addFileTransferListener(this);
}
 
开发者ID:ProjectMAXS,项目名称:maxs,代码行数:9,代码来源:XMPPFileTransfer.java


示例18: testInitializationSocks5FeaturesAndListenerOnStartup

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
/**
 * Socks5 feature should be added to the service discovery on Smack startup.
 * 
 * @throws XMPPException should not happen
 */
public void testInitializationSocks5FeaturesAndListenerOnStartup() throws XMPPException {
    Connection connection = getConnection(0);

    assertTrue(ServiceDiscoveryManager.getInstanceFor(connection).includesFeature(
                    Socks5BytestreamManager.NAMESPACE));

}
 
开发者ID:bejayoharen,项目名称:java-bells,代码行数:13,代码来源:Socks5ByteStreamTest.java


示例19: Socks5TransferNegotiator

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
Socks5TransferNegotiator(XMPPConnection connection) {
    this.connection = connection;
    this.manager = Socks5BytestreamManager.getBytestreamManager(this.connection);
}
 
开发者ID:TTalkIM,项目名称:Smack,代码行数:5,代码来源:Socks5TransferNegotiator.java


示例20: ByteStreamRequest

import org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager; //导入依赖的package包/类
private ByteStreamRequest(Socks5BytestreamManager manager, Bytestream byteStreamRequest) {
    super(manager, byteStreamRequest);
}
 
开发者ID:TTalkIM,项目名称:Smack,代码行数:4,代码来源:Socks5TransferNegotiator.java



注:本文中的org.jivesoftware.smackx.bytestreams.socks5.Socks5BytestreamManager类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java IntroduceTargetChooser类代码示例发布时间:2022-05-22
下一篇:
Java AbstractStreamOperator类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap