Package com.adaptris.jmx.remote.jms

Class JmsJmxConnectionFactoryImpl

java.lang.Object

com.adaptris.jmx.remote.jms.JmsJmxConnectionFactoryImpl

All Implemented Interfaces:

JmsJmxConnectionFactory, javax.jms.ConnectionFactory

public abstract class JmsJmxConnectionFactoryImpl
extends Object
implements JmsJmxConnectionFactory

Base class for JmsJmxConnectionFactory instances.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static enum	JmsJmxConnectionFactoryImpl.DestinationFactory
protected class	JmsJmxConnectionFactoryImpl.JmxJmsConnection

Field Summary

Fields

Modifier and Type	Field	Description
protected JmsJmxConnectionFactoryImpl.JmxJmsConnection	defaultConnection
protected JmsJmxConnectionFactoryImpl.DestinationFactory	destinationFactory
protected Map<String,?>	initialEnvironment
protected Map<String,String>	jmsEnvironment
protected Object	lock
protected static final org.slf4j.Logger	log

Fields inherited from interface com.adaptris.jmx.remote.jms.JmsJmxConnectionFactory

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JmsJmxConnectionFactoryImpl(Map<String,?> env, JMXServiceURL url)

Method Summary

Modifier and Type	Method	Description
protected void	addOpenedConnection(javax.jms.Connection c)
protected void	addTemporaryQueue(javax.jms.TemporaryQueue t)
protected void	addTemporaryTopic(javax.jms.TemporaryTopic t)
protected Map<String,String>	buildJmsEnvironment(Map<String,?> initial, Map<String,String> defaultEnv)
protected JmsJmxConnectionFactoryImpl.JmxJmsConnection	connect(javax.jms.ConnectionFactory factory, String loggingString)
protected Map<String,String>	createDefaultEnvironment()
com.adaptris.jmx.remote.jms.JmsInvokerProxy<?>	createInvokerProxy()	Create the invoker proxy.
protected final javax.jms.Queue	createQueueDestination(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 final javax.jms.Topic	createTopicDestination(String tName)
void	destroy()	Destroy any resources that may need destroying.
protected URI	getBrokerURI(JMXServiceURL serviceURL)
javax.jms.Destination	getTargetDestination()	Get the target dstination where you want to send requests and other things to.
protected static URI	maskUserInfo(URI uri)
protected static URI	newURI(URI uri, String query)
static Map<String,String>	parseParameters(URI uri)
protected static String	rebuildQuery(Map<String,String> params, Set<String> ignoreKeys)
static URI	removeQuery(URI uri)	Removes any URI query from the given uri
protected void	validateProtocol(String protocol)	Validate the protocol
protected abstract Collection<String>	validProtocols()
protected static javax.jms.JMSException	wrapJmsException(Throwable e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.ConnectionFactory

createConnection, createConnection

Field Details

log

protected static final org.slf4j.Logger log

initialEnvironment

protected transient Map<String,?> initialEnvironment

jmsEnvironment

protected transient Map<String,String> jmsEnvironment

defaultConnection

protected transient JmsJmxConnectionFactoryImpl.JmxJmsConnection defaultConnection

destinationFactory

protected transient JmsJmxConnectionFactoryImpl.DestinationFactory destinationFactory

lock

protected transient Object lock

Constructor Details

JmsJmxConnectionFactoryImpl

protected JmsJmxConnectionFactoryImpl(Map<String,?> env,
 JMXServiceURL url)
                               throws IOException

Throws:

IOException

Method Details

validateProtocol

protected void validateProtocol(String protocol)
                         throws MalformedURLException

Validate the protocol

Parameters:

protocol - the protocol from the JMXServiceURL

Throws:

MalformedURLException - if the protocol is invalid

validProtocols

protected abstract Collection<String> validProtocols()

createQueueDestination

protected final javax.jms.Queue createQueueDestination(String qName)
                                                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createTopicDestination

protected final javax.jms.Topic createTopicDestination(String tName)
                                                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createTemporaryDestination

public javax.jms.Destination createTemporaryDestination(javax.jms.Session s)
                                                 throws javax.jms.JMSException

Description copied from interface: JmsJmxConnectionFactory

Create a temporary destination (either a queue or a topic).

Specified by:

createTemporaryDestination in interface JmsJmxConnectionFactory

Parameters:

s - the session

Returns:

a TemporaryQueue or TemporaryTopic.

Throws:

javax.jms.JMSException - if there was an error creating the temporary destination.

connect

protected JmsJmxConnectionFactoryImpl.JmxJmsConnection connect(javax.jms.ConnectionFactory factory,
 String loggingString)

createDefaultEnvironment

protected Map<String,String> createDefaultEnvironment()

buildJmsEnvironment

protected Map<String,String> buildJmsEnvironment(Map<String,?> initial,
 Map<String,String> defaultEnv)

destroy

public void destroy()

Description copied from interface: JmsJmxConnectionFactory

Destroy any resources that may need destroying.

Specified by:

destroy in interface JmsJmxConnectionFactory

createInvokerProxy

public com.adaptris.jmx.remote.jms.JmsInvokerProxy<?> createInvokerProxy()
                                                                  throws javax.jms.JMSException

Description copied from interface: JmsJmxConnectionFactory

Create the invoker proxy.

Specified by:

createInvokerProxy in interface JmsJmxConnectionFactory

Returns:

a JmsInvokerProxy instance.

Throws:

javax.jms.JMSException - if there was an problem creating the invoker proxy.

createServiceExporter

public ExtendedJmsInvokerServiceExporter<?> createServiceExporter()
                                                           throws javax.jms.JMSException

Description copied from interface: JmsJmxConnectionFactory

Create the invoker proxy.

Specified by:

createServiceExporter in interface JmsJmxConnectionFactory

Returns:

a ExtendedJmsInvokerServiceExporter instance.

Throws:

javax.jms.JMSException - if there was an problem creating the ServiceExport proxy.

getTargetDestination

public javax.jms.Destination getTargetDestination()
                                           throws javax.jms.JMSException

Description copied from interface: JmsJmxConnectionFactory

Get the target dstination where you want to send requests and other things to.

Specified by:

getTargetDestination in interface JmsJmxConnectionFactory

Returns:

the destination.

Throws:

javax.jms.JMSException

addOpenedConnection

protected void addOpenedConnection(javax.jms.Connection c)

addTemporaryTopic

protected void addTemporaryTopic(javax.jms.TemporaryTopic t)

addTemporaryQueue

protected void addTemporaryQueue(javax.jms.TemporaryQueue t)

getBrokerURI

protected URI getBrokerURI(JMXServiceURL serviceURL)
                    throws URISyntaxException

Throws:

URISyntaxException

parseParameters

public static Map<String,String> parseParameters(URI uri)
                                          throws URISyntaxException

Throws:

URISyntaxException

rebuildQuery

protected static String rebuildQuery(Map<String,String> params,
 Set<String> ignoreKeys)
                              throws URISyntaxException

Throws:

URISyntaxException

removeQuery

public static URI removeQuery(URI uri)
                       throws URISyntaxException

Removes any URI query from the given uri

Throws:

URISyntaxException

maskUserInfo

protected static URI maskUserInfo(URI uri)
                           throws URISyntaxException

Throws:

URISyntaxException

newURI

protected static URI newURI(URI uri,
 String query)
                     throws URISyntaxException

Throws:

URISyntaxException

wrapJmsException

protected static javax.jms.JMSException wrapJmsException(Throwable e)