public abstract class JmsJmxConnectionFactoryImpl extends java.lang.Object implements JmsJmxConnectionFactory
JmsJmxConnectionFactory
instances.Modifier and Type | Class and Description |
---|---|
protected static class |
JmsJmxConnectionFactoryImpl.DestinationFactory |
protected class |
JmsJmxConnectionFactoryImpl.JmxJmsConnection |
Modifier and Type | Field and Description |
---|---|
protected JmsJmxConnectionFactoryImpl.JmxJmsConnection |
defaultConnection |
protected JmsJmxConnectionFactoryImpl.DestinationFactory |
destinationFactory |
protected java.util.Map<java.lang.String,?> |
initialEnvironment |
protected java.util.Map<java.lang.String,java.lang.String> |
jmsEnvironment |
protected java.lang.Object |
lock |
protected static org.slf4j.Logger |
log |
ATTR_BROKER_PASSWORD, ATTR_BROKER_USERNAME, ATTR_CLIENT_ID, ATTR_DESTINATION, ATTR_DESTINATION_TYPE, ATTR_RETRY_INTERVAL_MS, ATTR_TIMEOUT_MS, DEFAULT_RETRY_INTERVAL_MS, DEFAULT_TIMEOUT_MS
Modifier | Constructor and Description |
---|---|
protected |
JmsJmxConnectionFactoryImpl(java.util.Map<java.lang.String,?> env,
javax.management.remote.JMXServiceURL url) |
Modifier and Type | Method and Description |
---|---|
protected void |
addOpenedConnection(javax.jms.Connection c) |
protected void |
addTemporaryQueue(javax.jms.TemporaryQueue t) |
protected void |
addTemporaryTopic(javax.jms.TemporaryTopic t) |
protected java.util.Map<java.lang.String,java.lang.String> |
buildJmsEnvironment(java.util.Map<java.lang.String,?> initial,
java.util.Map<java.lang.String,java.lang.String> defaultEnv) |
protected JmsJmxConnectionFactoryImpl.JmxJmsConnection |
connect(javax.jms.ConnectionFactory factory,
java.lang.String loggingString) |
protected java.util.Map<java.lang.String,java.lang.String> |
createDefaultEnvironment() |
com.adaptris.jmx.remote.jms.JmsInvokerProxy |
createInvokerProxy()
Create the invoker proxy.
|
protected javax.jms.Queue |
createQueueDestination(java.lang.String qName) |
ExtendedJmsInvokerServiceExporter |
createServiceExporter()
Create the invoker proxy.
|
javax.jms.Destination |
createTemporaryDestination(javax.jms.Session s)
Create a temporary destination (either a queue or a topic).
|
protected javax.jms.Topic |
createTopicDestination(java.lang.String tName) |
void |
destroy()
Destroy any resources that may need destroying.
|
protected java.net.URI |
getBrokerURI(javax.management.remote.JMXServiceURL serviceURL) |
javax.jms.Destination |
getTargetDestination()
Get the target dstination where you want to send requests and other things to.
|
protected static java.net.URI |
maskUserInfo(java.net.URI uri) |
protected static java.net.URI |
newURI(java.net.URI uri,
java.lang.String query) |
static java.util.Map<java.lang.String,java.lang.String> |
parseParameters(java.net.URI uri) |
protected static java.lang.String |
rebuildQuery(java.util.Map<java.lang.String,java.lang.String> params,
java.util.Set<java.lang.String> ignoreKeys) |
static java.net.URI |
removeQuery(java.net.URI uri)
Removes any URI query from the given uri
|
protected void |
validateProtocol(java.lang.String protocol)
Validate the protocol
|
protected abstract java.util.Collection<java.lang.String> |
validProtocols() |
protected static javax.jms.JMSException |
wrapJmsException(java.lang.Throwable e) |
protected static final org.slf4j.Logger log
protected transient java.util.Map<java.lang.String,?> initialEnvironment
protected transient java.util.Map<java.lang.String,java.lang.String> jmsEnvironment
protected transient JmsJmxConnectionFactoryImpl.JmxJmsConnection defaultConnection
protected transient JmsJmxConnectionFactoryImpl.DestinationFactory destinationFactory
protected transient java.lang.Object lock
protected JmsJmxConnectionFactoryImpl(java.util.Map<java.lang.String,?> env, javax.management.remote.JMXServiceURL url) throws java.io.IOException
java.io.IOException
protected void validateProtocol(java.lang.String protocol) throws java.net.MalformedURLException
protocol
- the protocol from the JMXServiceURL
java.net.MalformedURLException
- if the protocol is invalidprotected abstract java.util.Collection<java.lang.String> validProtocols()
protected final javax.jms.Queue createQueueDestination(java.lang.String qName) throws javax.jms.JMSException
javax.jms.JMSException
protected final javax.jms.Topic createTopicDestination(java.lang.String tName) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Destination createTemporaryDestination(javax.jms.Session s) throws javax.jms.JMSException
JmsJmxConnectionFactory
createTemporaryDestination
in interface JmsJmxConnectionFactory
s
- the sessionTemporaryQueue
or TemporaryTopic
.javax.jms.JMSException
- if there was an error creating the temporary destination.protected JmsJmxConnectionFactoryImpl.JmxJmsConnection connect(javax.jms.ConnectionFactory factory, java.lang.String loggingString)
protected java.util.Map<java.lang.String,java.lang.String> createDefaultEnvironment()
protected java.util.Map<java.lang.String,java.lang.String> buildJmsEnvironment(java.util.Map<java.lang.String,?> initial, java.util.Map<java.lang.String,java.lang.String> defaultEnv)
public void destroy()
JmsJmxConnectionFactory
destroy
in interface JmsJmxConnectionFactory
public com.adaptris.jmx.remote.jms.JmsInvokerProxy createInvokerProxy() throws javax.jms.JMSException
JmsJmxConnectionFactory
createInvokerProxy
in interface JmsJmxConnectionFactory
JmsInvokerProxy
instance.javax.jms.JMSException
- if there was an problem creating the invoker proxy.public ExtendedJmsInvokerServiceExporter createServiceExporter() throws javax.jms.JMSException
JmsJmxConnectionFactory
createServiceExporter
in interface JmsJmxConnectionFactory
ExtendedJmsInvokerServiceExporter
instance.javax.jms.JMSException
- if there was an problem creating the ServiceExport proxy.public javax.jms.Destination getTargetDestination() throws javax.jms.JMSException
JmsJmxConnectionFactory
getTargetDestination
in interface JmsJmxConnectionFactory
javax.jms.JMSException
protected void addOpenedConnection(javax.jms.Connection c)
protected void addTemporaryTopic(javax.jms.TemporaryTopic t)
protected void addTemporaryQueue(javax.jms.TemporaryQueue t)
protected java.net.URI getBrokerURI(javax.management.remote.JMXServiceURL serviceURL) throws java.net.URISyntaxException
java.net.URISyntaxException
public static java.util.Map<java.lang.String,java.lang.String> parseParameters(java.net.URI uri) throws java.net.URISyntaxException
java.net.URISyntaxException
protected static java.lang.String rebuildQuery(java.util.Map<java.lang.String,java.lang.String> params, java.util.Set<java.lang.String> ignoreKeys) throws java.net.URISyntaxException
java.net.URISyntaxException
public static java.net.URI removeQuery(java.net.URI uri) throws java.net.URISyntaxException
java.net.URISyntaxException
protected static java.net.URI maskUserInfo(java.net.URI uri) throws java.net.URISyntaxException
java.net.URISyntaxException
protected static java.net.URI newURI(java.net.URI uri, java.lang.String query) throws java.net.URISyntaxException
java.net.URISyntaxException
protected static javax.jms.JMSException wrapJmsException(java.lang.Throwable e)