本文整理汇总了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;未经允许,请勿转载。 |
请发表评论