public class XmppConnector extends AbstractConnector
XmppConnector
represents a connection to a Jabber server.Modifier and Type | Field and Description |
---|---|
static String |
XMPP |
static String |
XMPP_FROM |
static String |
XMPP_GROUP_CHAT |
static String |
XMPP_NICKNAME |
static String |
XMPP_RECIPIENT |
static String |
XMPP_RESOURCE |
static String |
XMPP_SUBJECT |
static String |
XMPP_THREAD |
static String |
XMPP_TO |
static String |
XMPP_TYPE |
connecting, createMultipleTransactedReceivers, DEFAULT_CONTEXT_START_TIMEOUT, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, MULE_CONTEXT_START_TIMEOUT_SYSTEM_PROPERTY, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect
INT_VALUE_NOT_SET
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
XmppConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
connectToJabberServer() |
protected void |
createXmppConnection() |
protected void |
doConnect()
Template method where any connections should be made for the connector
|
protected void |
doDisconnect()
Template method where any connected resources used by the connector should be
disconnected
|
protected void |
doDispose()
Template method to perform any work when destroying the connectoe
|
protected void |
doInitialise() |
protected void |
doStart()
Template method to perform any work when starting the connectoe
|
protected void |
doStop()
Template method to perform any work when stopping the connectoe
|
XmppConversationFactory |
getConversationFactory() |
String |
getHost() |
String |
getPassword() |
int |
getPort() |
String |
getProtocol() |
protected static String |
getRecipient(ImmutableEndpoint endpoint) |
String |
getResource() |
String |
getServiceName() |
String |
getUser() |
protected org.jivesoftware.smack.XMPPConnection |
getXmppConnection() |
boolean |
isCreateAccount() |
boolean |
isResponseEnabled() |
void |
setConversationFactory(XmppConversationFactory conversationFactory) |
void |
setCreateAccount(boolean createAccount) |
void |
setHost(String host) |
void |
setPassword(String password) |
void |
setPort(int port) |
void |
setResource(String resource) |
void |
setServiceName(String serviceName) |
void |
setUser(String user) |
borrowDispatcher, clearDispatchers, clearRequesters, configureDispatcherPool, connect, connectConnectorAndReceivers, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createOperationResource, createReceiver, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, fireNotification, getCanonicalURI, getConnectEventId, getConnectionDescription, getDefaultExchangePattern, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherPoolFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getInboundExchangePatterns, getLifecycleState, getMaxDispatchersActive, getMaxRequestersActive, getMaxTotalDispatchers, getMuleContext, getMuleMessageFactory, getName, getNumberOfConcurrentTransactedReceivers, getOperationResourceFactory, getOutboundExchangePatterns, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, getTransactionalResource, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isConnecting, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isEnableMessageEvents, isInitialised, isInitialStateStopped, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerListener, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, returnDispatcher, setConnected, setConnecting, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherPoolFactory, setDispatcherPoolMaxWait, setDispatcherPoolWhenExhaustedAction, setDispatcherThreadingProfile, setDynamicNotification, setInitialStateStopped, setMaxDispatchersActive, setMaxRequestersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterPoolMaxWait, setRequesterPoolWhenExhaustedAction, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, shutdownScheduler, start, startAfterConnect, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted
getAnnotation, getAnnotations, setAnnotations
public static final String XMPP
public static final String XMPP_RESOURCE
public static final String XMPP_SUBJECT
public static final String XMPP_THREAD
public static final String XMPP_TO
public static final String XMPP_FROM
public static final String XMPP_GROUP_CHAT
public static final String XMPP_NICKNAME
public static final String XMPP_RECIPIENT
public static final String XMPP_TYPE
public XmppConnector(MuleContext context)
protected static String getRecipient(ImmutableEndpoint endpoint)
protected void doInitialise() throws InitialisationException
doInitialise
in class AbstractConnector
InitialisationException
protected void doDispose()
AbstractConnector
doDispose
in class AbstractConnector
protected void doConnect() throws Exception
AbstractConnector
doConnect
in class AbstractConnector
Exception
protected void doDisconnect() throws Exception
AbstractConnector
doDisconnect
in class AbstractConnector
Exception
protected void doStart() throws MuleException
AbstractConnector
doStart
in class AbstractConnector
MuleException
- if the method failsprotected void doStop() throws MuleException
AbstractConnector
doStop
in class AbstractConnector
MuleException
- if the method failspublic String getProtocol()
protected void createXmppConnection() throws org.jivesoftware.smack.XMPPException
org.jivesoftware.smack.XMPPException
protected void connectToJabberServer() throws org.jivesoftware.smack.XMPPException
org.jivesoftware.smack.XMPPException
public boolean isResponseEnabled()
isResponseEnabled
in interface Connector
isResponseEnabled
in class AbstractConnector
public String getHost()
public void setHost(String host)
public int getPort()
public void setPort(int port)
public String getServiceName()
public void setServiceName(String serviceName)
public String getUser()
public void setUser(String user)
public String getPassword()
public void setPassword(String password)
public String getResource()
public void setResource(String resource)
public boolean isCreateAccount()
public void setCreateAccount(boolean createAccount)
public XmppConversationFactory getConversationFactory()
public void setConversationFactory(XmppConversationFactory conversationFactory)
protected org.jivesoftware.smack.XMPPConnection getXmppConnection()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.