won.protocol.jms

Class ActiveMQServiceImpl

java.lang.Object

won.protocol.jms.ActiveMQServiceImpl

All Implemented Interfaces:

ActiveMQService, MessageBrokerService

Direct Known Subclasses:

MatcherActiveMQServiceImpl

public class ActiveMQServiceImpl
extends java.lang.Object
implements ActiveMQService

User: sbyim Date: 28.11.13

Field Summary

Fields

Modifier and Type	Field and Description
protected LinkedDataSource	linkedDataSource
protected java.lang.String	queueNamePath

Constructor Summary

Constructors

Constructor and Description
ActiveMQServiceImpl(ProtocolType type)

Method Summary

Modifier and Type	Method and Description
java.net.URI	getBrokerEndpoint(java.net.URI resourceUri) Extracts the ActiveMQ broker endpoint for connecting via ActiveMQ to the atom or WON node identified by the specified resourceUri.
java.util.Set<java.lang.String>	getMatcherProtocolTopicNamesWithResource(java.net.URI resourceURI)
java.lang.String	getProtocolQueueNameWithResource(java.net.URI resourceUri) Extracts the ActiveMQ queue name for connecting via ActiveMQ to the atom or WON node identified by the specified resourceUri.
void	setLinkedDataSource(LinkedDataSource linkedDataSource)

Methods inherited from class java.lang.Object

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

Field Detail

queueNamePath

protected java.lang.String queueNamePath

linkedDataSource

@Autowired
 @Qualifier(value="default")
protected LinkedDataSource linkedDataSource

Constructor Detail

ActiveMQServiceImpl

public ActiveMQServiceImpl(ProtocolType type)

Method Detail

getProtocolQueueNameWithResource

public final java.lang.String getProtocolQueueNameWithResource(java.net.URI resourceUri)

Description copied from interface: ActiveMQService

Extracts the ActiveMQ queue name for connecting via ActiveMQ to the atom or WON node identified by the specified resourceUri.

Specified by:

getProtocolQueueNameWithResource in interface ActiveMQService

Returns:

getBrokerEndpoint

public final java.net.URI getBrokerEndpoint(java.net.URI resourceUri)

Description copied from interface: MessageBrokerService

Extracts the ActiveMQ broker endpoint for connecting via ActiveMQ to the atom or WON node identified by the specified resourceUri.

Specified by:

getBrokerEndpoint in interface MessageBrokerService

Returns:

getMatcherProtocolTopicNamesWithResource

public java.util.Set<java.lang.String> getMatcherProtocolTopicNamesWithResource(java.net.URI resourceURI)

setLinkedDataSource

public void setLinkedDataSource(LinkedDataSource linkedDataSource)