Package org.apache.activemq.artemis.core.protocol.openwire

Class OpenWireProtocolManager

java.lang.Object

org.apache.activemq.artemis.spi.core.protocol.AbstractProtocolManager<org.apache.activemq.command.Command,OpenWireInterceptor,OpenWireConnection,OpenWireRoutingHandler>

org.apache.activemq.artemis.core.protocol.openwire.OpenWireProtocolManager

All Implemented Interfaces:

ClusterTopologyListener, ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

public class OpenWireProtocolManager
extends AbstractProtocolManager<org.apache.activemq.command.Command,OpenWireInterceptor,OpenWireConnection,OpenWireRoutingHandler>
implements ClusterTopologyListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	OpenWireProtocolManager.VirtualTopicConfig

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.activemq.command.ProducerId	advisoryProducerId
protected org.apache.activemq.artemis.selector.impl.LRUCache<org.apache.activemq.command.ActiveMQDestination,org.apache.activemq.command.ActiveMQDestination>	vtDestMapCache

Constructor Summary

Constructors

Constructor	Description
OpenWireProtocolManager(OpenWireProtocolManagerFactory factory, ActiveMQServer server, List<BaseInterceptor> incomingInterceptors, List<BaseInterceptor> outgoingInterceptors)

Method Summary

Modifier and Type	Method	Description
boolean	acceptsNoHandshake()
void	addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)
void	addConnection(OpenWireConnection connection, org.apache.activemq.command.ConnectionInfo info)
void	configureInactivityParams(OpenWireConnection connection, org.apache.activemq.command.WireFormatInfo command)
ConnectionEntry	createConnectionEntry(Acceptor acceptorUsed, Connection connection)
void	fireAdvisory(AMQConnectionContext context, org.apache.activemq.command.ActiveMQTopic topic, org.apache.activemq.command.Command copy)
void	fireAdvisory(AMQConnectionContext context, org.apache.activemq.command.ActiveMQTopic topic, org.apache.activemq.command.Command command, org.apache.activemq.command.ConsumerId targetConsumerId, String originalConnectionId)
int	getActorThresholdBytes()	if set, the OpenWire connection will bypass the tcpReadBuferSize and use this value instead.
org.apache.activemq.command.BrokerId	getBrokerId()
String	getBrokerName()
List<OpenWireConnection>	getConnections()
ProtocolManagerFactory	getFactory()
long	getMaxInactivityDuration()
long	getMaxInactivityDurationInitalDelay()
int	getOpenWireDestinationCacheSize()
int	getOpenwireMaxPacketChunkSize()	if defined, LargeMessages will be sent in chunks to the network.
Map<SimpleString,RoutingType>	getPrefixes()
OpenWireRoutingHandler	getRoutingHandler()
ScheduledExecutorService	getScheduledPool()
String	getSecurityDomain()
ActiveMQServer	getServer()
List<org.apache.activemq.command.DestinationInfo>	getTemporaryDestinations()
void	handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)
void	handshake(NettyServerConnection connection, ActiveMQBuffer buffer)
String	invokeIncoming(org.apache.activemq.command.Command command, OpenWireConnection connection)
String	invokeOutgoing(org.apache.activemq.command.Command command, OpenWireConnection connection)
boolean	isFaultTolerantConfiguration()
boolean	isOpenwireUseDuplicateDetectionOnFailover()	Is Duplicate detection enabled when used with failover clients.
boolean	isProtocol(byte[] array)
boolean	isRebalanceClusterClients()	URI property
boolean	isStopped()
boolean	isStopping()
boolean	isSupportAdvisory()
boolean	isSuppressInternalManagementObjects()
boolean	isUpdateClusterClients()
boolean	isUpdateClusterClientsOnRemove()	URI property
boolean	isUseKeepAlive()
protected org.apache.activemq.command.ConnectionControl	newConnectionControl()
void	nodeDown(long eventUID, String nodeID)
void	nodeUP(TopologyMember member, boolean last)
void	postProcessDispatch(org.apache.activemq.command.MessageDispatch md)
void	preProcessDispatch(org.apache.activemq.command.MessageDispatch messageDispatch)
void	removeConnection(org.apache.activemq.command.ConnectionInfo info, Throwable error)
void	sendBrokerInfo(OpenWireConnection connection)
OpenWireProtocolManager	setActorThresholdBytes(int actorThresholdBytes)
void	setAnycastPrefix(String anycastPrefix)
void	setBrokerName(String name)
void	setMaxInactivityDuration(long maxInactivityDuration)
void	setMaxInactivityDurationInitalDelay(long maxInactivityDurationInitalDelay)
void	setMulticastPrefix(String multicastPrefix)
void	setOpenWireDestinationCacheSize(int openWireDestinationCacheSize)
OpenWireProtocolManager	setOpenwireMaxPacketChunkSize(int openwireMaxPacketChunkSize)
OpenWireProtocolManager	setOpenwireUseDuplicateDetectionOnFailover(boolean openwireUseDuplicateDetectionOnFailover)	should it use duplicate detection on failover clients.
void	setRebalanceClusterClients(boolean rebalance)	URI property
void	setSecurityDomain(String securityDomain)
void	setSupportAdvisory(boolean supportAdvisory)
void	setSuppressInternalManagementObjects(boolean suppressInternalManagementObjects)
void	setUpdateClusterClients(boolean updateClusterClients)	URI property
void	setUpdateClusterClientsOnRemove(boolean updateClusterClientsOnRemove)	URI property
void	setUseKeepAlive(boolean useKeepAlive)
void	setVirtualTopicConsumerLruCacheMax(int max)
void	setVirtualTopicConsumerWildcards(String virtualTopicConsumerWildcards)
void	updateInterceptors(List incoming, List outgoing)
String	validateUser(String login, String passcode, OpenWireConnection connection)
void	validateUser(OpenWireConnection connection, org.apache.activemq.command.ConnectionInfo info)
org.apache.activemq.command.ActiveMQDestination	virtualTopicConsumerToFQQN(org.apache.activemq.command.ActiveMQDestination destination)
List<String>	websocketSubprotocolIdentifiers()
org.apache.activemq.openwire.OpenWireFormat	wireFormat()

Methods inherited from class org.apache.activemq.artemis.spi.core.protocol.AbstractProtocolManager

invokeInterceptors

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.spi.core.protocol.ProtocolManager

removeHandler

Field Detail

advisoryProducerId

protected final org.apache.activemq.command.ProducerId advisoryProducerId

vtDestMapCache

protected final org.apache.activemq.artemis.selector.impl.LRUCache<org.apache.activemq.command.ActiveMQDestination,org.apache.activemq.command.ActiveMQDestination> vtDestMapCache

Constructor Detail

OpenWireProtocolManager

public OpenWireProtocolManager(OpenWireProtocolManagerFactory factory,
                               ActiveMQServer server,
                               List<BaseInterceptor> incomingInterceptors,
                               List<BaseInterceptor> outgoingInterceptors)

Method Detail

getOpenwireMaxPacketChunkSize

public int getOpenwireMaxPacketChunkSize()

if defined, LargeMessages will be sent in chunks to the network. Notice that the system will still load the entire file in memory before sending on the stream. This should avoid just a big buffer allocated.

setOpenwireMaxPacketChunkSize

public OpenWireProtocolManager setOpenwireMaxPacketChunkSize(int openwireMaxPacketChunkSize)

isOpenwireUseDuplicateDetectionOnFailover

public boolean isOpenwireUseDuplicateDetectionOnFailover()

Is Duplicate detection enabled when used with failover clients.

setOpenwireUseDuplicateDetectionOnFailover

public OpenWireProtocolManager setOpenwireUseDuplicateDetectionOnFailover(boolean openwireUseDuplicateDetectionOnFailover)

should it use duplicate detection on failover clients.

nodeUP

public void nodeUP(TopologyMember member,
                   boolean last)

Specified by:

nodeUP in interface ClusterTopologyListener

nodeDown

public void nodeDown(long eventUID,
                     String nodeID)

Specified by:

nodeDown in interface ClusterTopologyListener

removeConnection

public void removeConnection(org.apache.activemq.command.ConnectionInfo info,
                             Throwable error)
                      throws javax.jms.InvalidClientIDException

Throws:

javax.jms.InvalidClientIDException

getActorThresholdBytes

public int getActorThresholdBytes()

if set, the OpenWire connection will bypass the tcpReadBuferSize and use this value instead. This is by default -1, and it should not be used unless in extreme situations like on a slow storage.

setActorThresholdBytes

public OpenWireProtocolManager setActorThresholdBytes(int actorThresholdBytes)

getScheduledPool

public ScheduledExecutorService getScheduledPool()

getServer

public ActiveMQServer getServer()

acceptsNoHandshake

public boolean acceptsNoHandshake()

Specified by:

acceptsNoHandshake in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

getFactory

public ProtocolManagerFactory getFactory()

Specified by:

getFactory in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

updateInterceptors

public void updateInterceptors(List incoming,
                               List outgoing)

Specified by:

updateInterceptors in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

invokeIncoming

public String invokeIncoming(org.apache.activemq.command.Command command,
                             OpenWireConnection connection)

invokeOutgoing

public String invokeOutgoing(org.apache.activemq.command.Command command,
                             OpenWireConnection connection)

createConnectionEntry

public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed,
                                             Connection connection)

Specified by:

createConnectionEntry in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

handleBuffer

public void handleBuffer(RemotingConnection connection,
                         ActiveMQBuffer buffer)

Specified by:

handleBuffer in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

addChannelHandlers

public void addChannelHandlers(io.netty.channel.ChannelPipeline pipeline)

Specified by:

addChannelHandlers in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

isProtocol

public boolean isProtocol(byte[] array)

Specified by:

isProtocol in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

handshake

public void handshake(NettyServerConnection connection,
                      ActiveMQBuffer buffer)

Specified by:

handshake in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

websocketSubprotocolIdentifiers

public List<String> websocketSubprotocolIdentifiers()

Specified by:

websocketSubprotocolIdentifiers in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

validateUser

public void validateUser(OpenWireConnection connection,
                         org.apache.activemq.command.ConnectionInfo info)
                  throws Exception

Throws:

Exception

addConnection

public void addConnection(OpenWireConnection connection,
                          org.apache.activemq.command.ConnectionInfo info)
                   throws Exception

Throws:

Exception

fireAdvisory

public void fireAdvisory(AMQConnectionContext context,
                         org.apache.activemq.command.ActiveMQTopic topic,
                         org.apache.activemq.command.Command copy)
                  throws Exception

Throws:

Exception

getBrokerId

public org.apache.activemq.command.BrokerId getBrokerId()

fireAdvisory

public void fireAdvisory(AMQConnectionContext context,
                         org.apache.activemq.command.ActiveMQTopic topic,
                         org.apache.activemq.command.Command command,
                         org.apache.activemq.command.ConsumerId targetConsumerId,
                         String originalConnectionId)
                  throws Exception

Throws:

Exception

getBrokerName

public String getBrokerName()

newConnectionControl

protected org.apache.activemq.command.ConnectionControl newConnectionControl()

isFaultTolerantConfiguration

public boolean isFaultTolerantConfiguration()

postProcessDispatch

public void postProcessDispatch(org.apache.activemq.command.MessageDispatch md)

isStopped

public boolean isStopped()

preProcessDispatch

public void preProcessDispatch(org.apache.activemq.command.MessageDispatch messageDispatch)

isStopping

public boolean isStopping()

validateUser

public String validateUser(String login,
                           String passcode,
                           OpenWireConnection connection)
                    throws Exception

Throws:

Exception

sendBrokerInfo

public void sendBrokerInfo(OpenWireConnection connection)
                    throws Exception

Throws:

Exception

configureInactivityParams

public void configureInactivityParams(OpenWireConnection connection,
                                      org.apache.activemq.command.WireFormatInfo command)
                               throws IOException

Throws:

IOException

setRebalanceClusterClients

public void setRebalanceClusterClients(boolean rebalance)

URI property

isRebalanceClusterClients

public boolean isRebalanceClusterClients()

URI property

setUpdateClusterClients

public void setUpdateClusterClients(boolean updateClusterClients)

URI property

isUpdateClusterClients

public boolean isUpdateClusterClients()

setUpdateClusterClientsOnRemove

public void setUpdateClusterClientsOnRemove(boolean updateClusterClientsOnRemove)

URI property

isUpdateClusterClientsOnRemove

public boolean isUpdateClusterClientsOnRemove()

URI property

setBrokerName

public void setBrokerName(String name)

isUseKeepAlive

public boolean isUseKeepAlive()

setUseKeepAlive

public void setUseKeepAlive(boolean useKeepAlive)

getMaxInactivityDuration

public long getMaxInactivityDuration()

setMaxInactivityDuration

public void setMaxInactivityDuration(long maxInactivityDuration)

getMaxInactivityDurationInitalDelay

public long getMaxInactivityDurationInitalDelay()

setMaxInactivityDurationInitalDelay

public void setMaxInactivityDurationInitalDelay(long maxInactivityDurationInitalDelay)

setAnycastPrefix

public void setAnycastPrefix(String anycastPrefix)

Specified by:

setAnycastPrefix in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

Overrides:

setAnycastPrefix in class AbstractProtocolManager<org.apache.activemq.command.Command,OpenWireInterceptor,OpenWireConnection,OpenWireRoutingHandler>

setMulticastPrefix

public void setMulticastPrefix(String multicastPrefix)

Specified by:

setMulticastPrefix in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

Overrides:

setMulticastPrefix in class AbstractProtocolManager<org.apache.activemq.command.Command,OpenWireInterceptor,OpenWireConnection,OpenWireRoutingHandler>

getPrefixes

public Map<SimpleString,RoutingType> getPrefixes()

Specified by:

getPrefixes in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

Overrides:

getPrefixes in class AbstractProtocolManager<org.apache.activemq.command.Command,OpenWireInterceptor,OpenWireConnection,OpenWireRoutingHandler>

setSecurityDomain

public void setSecurityDomain(String securityDomain)

Specified by:

setSecurityDomain in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

Overrides:

setSecurityDomain in class AbstractProtocolManager<org.apache.activemq.command.Command,OpenWireInterceptor,OpenWireConnection,OpenWireRoutingHandler>

getRoutingHandler

public OpenWireRoutingHandler getRoutingHandler()

Specified by:

getRoutingHandler in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

getSecurityDomain

public String getSecurityDomain()

Specified by:

getSecurityDomain in interface ProtocolManager<OpenWireInterceptor,OpenWireRoutingHandler>

Overrides:

getSecurityDomain in class AbstractProtocolManager<org.apache.activemq.command.Command,OpenWireInterceptor,OpenWireConnection,OpenWireRoutingHandler>

getTemporaryDestinations

public List<org.apache.activemq.command.DestinationInfo> getTemporaryDestinations()

wireFormat

public org.apache.activemq.openwire.OpenWireFormat wireFormat()

isSupportAdvisory

public boolean isSupportAdvisory()

setSupportAdvisory

public void setSupportAdvisory(boolean supportAdvisory)

isSuppressInternalManagementObjects

public boolean isSuppressInternalManagementObjects()

setSuppressInternalManagementObjects

public void setSuppressInternalManagementObjects(boolean suppressInternalManagementObjects)

getOpenWireDestinationCacheSize

public int getOpenWireDestinationCacheSize()

setOpenWireDestinationCacheSize

public void setOpenWireDestinationCacheSize(int openWireDestinationCacheSize)

setVirtualTopicConsumerWildcards

public void setVirtualTopicConsumerWildcards(String virtualTopicConsumerWildcards)

setVirtualTopicConsumerLruCacheMax

public void setVirtualTopicConsumerLruCacheMax(int max)

virtualTopicConsumerToFQQN

public org.apache.activemq.command.ActiveMQDestination virtualTopicConsumerToFQQN(org.apache.activemq.command.ActiveMQDestination destination)

getConnections

public List<OpenWireConnection> getConnections()