Package com.adaptris.core.jcsmp.solace
Class SolaceJcsmpConnection
- java.lang.Object
-
- com.adaptris.core.AdaptrisConnectionImp
-
- com.adaptris.core.AllowsRetriesConnection
-
- com.adaptris.core.jcsmp.solace.SolaceJcsmpConnection
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisConnection
,ComponentLifecycle
,ComponentLifecycleExtension
,SolaceJcsmpSessionCreator
,StateManagedComponent
@ComponentProfile(summary="A Solace native JCSMP connection used to create JCSMP sessions to your Solace appliance.", tag="connection,solace,jcsmp", since="3.9.3") public class SolaceJcsmpConnection extends AllowsRetriesConnection implements SolaceJcsmpSessionCreator
The Interlok
AdaptrisConnection
that will allow us to connect to your Solace router via the JCSMP api.Simply supply the host, vpn name, user and password.
In the adapter configuration file this class is aliased as solace-jcsmp-connection which is the preferred alternative to the fully qualified classname when building your configuration.
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisConnectionImp
log
-
-
Constructor Summary
Constructors Constructor Description SolaceJcsmpConnection()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected boolean
additionalDebug()
protected void
closeConnection()
com.solacesystems.jcsmp.JCSMPSession
createSession()
java.lang.Boolean
getAdditionalDebug()
AuthenticationProvider
getAuthenticationProvider()
How would you like to be authenticated when connecting to Solace.java.lang.String
getHost()
The tcp address to your Solace router, such as "tcp://localhost:55555".java.lang.String
getVpn()
The Solace VPN name, such as "default".protected void
initConnection()
protected void
prepareConnection()
void
setAdditionalDebug(java.lang.Boolean additionalDebug)
void
setAuthenticationProvider(AuthenticationProvider authenticationProvider)
How would you like to be authenticated when connecting to Solace.void
setHost(java.lang.String host)
The tcp address to your Solace router, such as "tcp://localhost:55555".void
setVpn(java.lang.String vpn)
The Solace VPN name, such as "default".protected void
startConnection()
protected void
stopConnection()
-
Methods inherited from class com.adaptris.core.AllowsRetriesConnection
connectionAttempts, connectionRetryInterval, createLoggingStatement, getConnectionAttempts, getConnectionRetryInterval, logWarning, setConnectionAttempts, setConnectionRetryInterval
-
Methods inherited from class com.adaptris.core.AdaptrisConnectionImp
addExceptionListener, addMessageConsumer, addMessageProducer, changeState, cloneForTesting, close, connectionErrorHandler, getConnectionErrorHandler, getUniqueId, getWorkersFirstOnShutdown, init, prepare, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, retrieveConnection, retrieveExceptionListeners, retrieveMessageConsumers, retrieveMessageProducers, setConnectionErrorHandler, setUniqueId, setWorkersFirstOnShutdown, start, stop, workersFirstOnShutdown
-
-
-
-
Method Detail
-
createSession
public com.solacesystems.jcsmp.JCSMPSession createSession() throws java.lang.Exception
- Specified by:
createSession
in interfaceSolaceJcsmpSessionCreator
- Throws:
java.lang.Exception
-
prepareConnection
protected void prepareConnection() throws CoreException
- Specified by:
prepareConnection
in classAdaptrisConnectionImp
- Throws:
CoreException
-
initConnection
protected void initConnection() throws CoreException
- Specified by:
initConnection
in classAdaptrisConnectionImp
- Throws:
CoreException
-
startConnection
protected void startConnection() throws CoreException
- Specified by:
startConnection
in classAdaptrisConnectionImp
- Throws:
CoreException
-
stopConnection
protected void stopConnection()
- Specified by:
stopConnection
in classAdaptrisConnectionImp
-
closeConnection
protected void closeConnection()
- Specified by:
closeConnection
in classAdaptrisConnectionImp
-
additionalDebug
protected boolean additionalDebug()
-
getHost
public java.lang.String getHost()
The tcp address to your Solace router, such as "tcp://localhost:55555".
-
setHost
public void setHost(java.lang.String host)
The tcp address to your Solace router, such as "tcp://localhost:55555".- Parameters:
host
-
-
getVpn
public java.lang.String getVpn()
The Solace VPN name, such as "default".
-
setVpn
public void setVpn(java.lang.String vpn)
The Solace VPN name, such as "default".- Parameters:
vpn
-
-
getAuthenticationProvider
public AuthenticationProvider getAuthenticationProvider()
How would you like to be authenticated when connecting to Solace.
-
setAuthenticationProvider
public void setAuthenticationProvider(AuthenticationProvider authenticationProvider)
How would you like to be authenticated when connecting to Solace.
-
getAdditionalDebug
public java.lang.Boolean getAdditionalDebug()
-
setAdditionalDebug
public void setAdditionalDebug(java.lang.Boolean additionalDebug)
-
-