Package org.apache.activemq.artemis.core.client

Class ActiveMQClientMessageBundle_impl

java.lang.Object

org.apache.activemq.artemis.core.client.ActiveMQClientMessageBundle_impl

All Implemented Interfaces:

ActiveMQClientMessageBundle

public class ActiveMQClientMessageBundle_impl
extends Object
implements ActiveMQClientMessageBundle

Field Summary

Fields inherited from interface org.apache.activemq.artemis.core.client.ActiveMQClientMessageBundle

BUNDLE

Constructor Summary

Constructors

Constructor	Description
ActiveMQClientMessageBundle_impl(Logger logger)

Method Summary

Modifier and Type	Method	Description
ActiveMQAddressFullException	addressIsFull(String addressName, int size)
IllegalArgumentException	attsDontMatch(String name, String value)
ActiveMQNotConnectedException	cannotConnectToServers()
ActiveMQNotConnectedException	cannotConnectToStaticConnectors(Exception e)
ActiveMQNotConnectedException	cannotConnectToStaticConnectors2()
IllegalStateException	cannotSendPacketDuringFailover()
ActiveMQNotConnectedException	channelDisconnected()
ActiveMQInternalErrorException	clientSessionClosed()
IllegalArgumentException	closeListenerCannotBeNull()
ActiveMQObjectClosedException	connectionClosedOnReceiveTopology(DiscoveryGroup discoveryGroup)
ActiveMQNotConnectedException	connectionDestroyed()
IllegalArgumentException	connectionExists(Object id)
ActiveMQConnectionTimedOutException	connectionTimedOut(Connection transportConnection)
ActiveMQConnectionTimedOutException	connectionTimedOutInInitialBroadcast()
ActiveMQConnectionTimedOutException	connectionTimedOutOnReceiveTopology(DiscoveryGroup discoveryGroup)
ActiveMQObjectClosedException	consumerClosed()
ActiveMQDisconnectedException	disconnected()
ActiveMQLargeMessageException	errorClosingLargeMessage(Exception e)
IllegalArgumentException	errordecodingPassword(Exception e)
ActiveMQLargeMessageException	errorReadingBody(Exception e)
ActiveMQLargeMessageException	errorSavingBody(Exception e)
ActiveMQLargeMessageException	errorWritingLargeMessage(Exception e)
ActiveMQInternalErrorException	failedToCreateSession(Throwable t)
RuntimeException	failedToHandlePacket(Exception e)
ActiveMQInternalErrorException	failedToInitialiseSessionFactory(Exception e)
IllegalArgumentException	failListenerCannotBeNull()
IllegalArgumentException	firstNodeNull()
ActiveMQIllegalStateException	headerSizeTooBig(Integer headerSize)
ActiveMQIllegalStateException	inReceive()
ActiveMQInterceptorRejectedPacketException	interceptorRejectedPacket(String interceptionResult)
IllegalArgumentException	invalidEncodeType(Object type)
IllegalStateException	invalidPacket(byte type)
IllegalArgumentException	invalidType(Object type)
IllegalArgumentException	invalidWindowSize(Integer size)
IllegalArgumentException	keystoreAliasNotFound(String keystoreAlias, String keystorePath)
ActiveMQLargeMessageInterruptedException	largeMessageInterrupted()
ActiveMQIllegalStateException	largeMessageLostSession()
ActiveMQIllegalStateException	messageHandlerSet()
IllegalArgumentException	mustBeBoolean(Node elem, String value)
IllegalArgumentException	mustBeDouble(Node elem, String value)
IllegalArgumentException	mustBeInteger(Node elem, String value)
IllegalArgumentException	mustBeLong(Node element, String value)
IllegalArgumentException	noChannelToClose(Long id)
IllegalArgumentException	nodeHasDifferentChildNumber()
IllegalArgumentException	nodeHaveDifferentAttNumber()
IllegalArgumentException	nodeHaveDifferentNames()
ActiveMQIllegalStateException	noTCForSessionFactory()
IllegalArgumentException	nullHandler()
IllegalArgumentException	nullListener()
IllegalArgumentException	oneNodeHasChildren()
ActiveMQInterruptedException	packetTransmissionInterrupted()
ActiveMQObjectClosedException	producerClosed()
ActiveMQInternalErrorException	queueMisConfigured()
ActiveMQRoutingException	redirected()
IllegalArgumentException	secondNodeNull()
ActiveMQObjectClosedException	sessionClosed()
ActiveMQConnectionTimedOutException	timedOutSendingPacket(long timeout, Byte type)
ActiveMQLargeMessageException	timeoutOnLargeMessage()
ActiveMQTransactionOutcomeUnknownException	txOutcomeUnknown()
ActiveMQTransactionRolledBackException	txRolledBack()
IllegalStateException	unableToCreateSession()
ActiveMQUnBlockedException	unblockingACall(Throwable t)

Methods inherited from class java.lang.Object

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

Constructor Details

ActiveMQClientMessageBundle_impl

public ActiveMQClientMessageBundle_impl(Logger logger)

Method Details

clientSessionClosed

public ActiveMQInternalErrorException clientSessionClosed()

Specified by:

clientSessionClosed in interface ActiveMQClientMessageBundle

failedToCreateSession

public ActiveMQInternalErrorException failedToCreateSession(Throwable t)

Specified by:

failedToCreateSession in interface ActiveMQClientMessageBundle

queueMisConfigured

public ActiveMQInternalErrorException queueMisConfigured()

Specified by:

queueMisConfigured in interface ActiveMQClientMessageBundle

failedToInitialiseSessionFactory

public ActiveMQInternalErrorException failedToInitialiseSessionFactory(Exception e)

Specified by:

failedToInitialiseSessionFactory in interface ActiveMQClientMessageBundle

channelDisconnected

public ActiveMQNotConnectedException channelDisconnected()

Specified by:

channelDisconnected in interface ActiveMQClientMessageBundle

cannotConnectToServers

public ActiveMQNotConnectedException cannotConnectToServers()

Specified by:

cannotConnectToServers in interface ActiveMQClientMessageBundle

cannotConnectToStaticConnectors

public ActiveMQNotConnectedException cannotConnectToStaticConnectors(Exception e)

Specified by:

cannotConnectToStaticConnectors in interface ActiveMQClientMessageBundle

cannotConnectToStaticConnectors2

public ActiveMQNotConnectedException cannotConnectToStaticConnectors2()

Specified by:

cannotConnectToStaticConnectors2 in interface ActiveMQClientMessageBundle

connectionDestroyed

public ActiveMQNotConnectedException connectionDestroyed()

Specified by:

connectionDestroyed in interface ActiveMQClientMessageBundle

connectionTimedOut

public ActiveMQConnectionTimedOutException connectionTimedOut(Connection transportConnection)

Specified by:

connectionTimedOut in interface ActiveMQClientMessageBundle

connectionTimedOutInInitialBroadcast

public ActiveMQConnectionTimedOutException connectionTimedOutInInitialBroadcast()

Specified by:

connectionTimedOutInInitialBroadcast in interface ActiveMQClientMessageBundle

connectionTimedOutOnReceiveTopology

public ActiveMQConnectionTimedOutException connectionTimedOutOnReceiveTopology(DiscoveryGroup discoveryGroup)

Specified by:

connectionTimedOutOnReceiveTopology in interface ActiveMQClientMessageBundle

timedOutSendingPacket

public ActiveMQConnectionTimedOutException timedOutSendingPacket(long timeout,
 Byte type)

Specified by:

timedOutSendingPacket in interface ActiveMQClientMessageBundle

disconnected

public ActiveMQDisconnectedException disconnected()

Specified by:

disconnected in interface ActiveMQClientMessageBundle

unblockingACall

public ActiveMQUnBlockedException unblockingACall(Throwable t)

Specified by:

unblockingACall in interface ActiveMQClientMessageBundle

consumerClosed

public ActiveMQObjectClosedException consumerClosed()

Specified by:

consumerClosed in interface ActiveMQClientMessageBundle

producerClosed

public ActiveMQObjectClosedException producerClosed()

Specified by:

producerClosed in interface ActiveMQClientMessageBundle

sessionClosed

public ActiveMQObjectClosedException sessionClosed()

Specified by:

sessionClosed in interface ActiveMQClientMessageBundle

messageHandlerSet

public ActiveMQIllegalStateException messageHandlerSet()

Specified by:

messageHandlerSet in interface ActiveMQClientMessageBundle

inReceive

public ActiveMQIllegalStateException inReceive()

Specified by:

inReceive in interface ActiveMQClientMessageBundle

headerSizeTooBig

public ActiveMQIllegalStateException headerSizeTooBig(Integer headerSize)

Specified by:

headerSizeTooBig in interface ActiveMQClientMessageBundle

largeMessageLostSession

public ActiveMQIllegalStateException largeMessageLostSession()

Specified by:

largeMessageLostSession in interface ActiveMQClientMessageBundle

noTCForSessionFactory

public ActiveMQIllegalStateException noTCForSessionFactory()

Specified by:

noTCForSessionFactory in interface ActiveMQClientMessageBundle

errorSavingBody

public ActiveMQLargeMessageException errorSavingBody(Exception e)

Specified by:

errorSavingBody in interface ActiveMQClientMessageBundle

errorReadingBody

public ActiveMQLargeMessageException errorReadingBody(Exception e)

Specified by:

errorReadingBody in interface ActiveMQClientMessageBundle

errorClosingLargeMessage

public ActiveMQLargeMessageException errorClosingLargeMessage(Exception e)

Specified by:

errorClosingLargeMessage in interface ActiveMQClientMessageBundle

timeoutOnLargeMessage

public ActiveMQLargeMessageException timeoutOnLargeMessage()

Specified by:

timeoutOnLargeMessage in interface ActiveMQClientMessageBundle

errorWritingLargeMessage

public ActiveMQLargeMessageException errorWritingLargeMessage(Exception e)

Specified by:

errorWritingLargeMessage in interface ActiveMQClientMessageBundle

txRolledBack

public ActiveMQTransactionRolledBackException txRolledBack()

Specified by:

txRolledBack in interface ActiveMQClientMessageBundle

txOutcomeUnknown

public ActiveMQTransactionOutcomeUnknownException txOutcomeUnknown()

Specified by:

txOutcomeUnknown in interface ActiveMQClientMessageBundle

invalidType

public IllegalArgumentException invalidType(Object type)

Specified by:

invalidType in interface ActiveMQClientMessageBundle

invalidEncodeType

public IllegalArgumentException invalidEncodeType(Object type)

Specified by:

invalidEncodeType in interface ActiveMQClientMessageBundle

invalidWindowSize

public IllegalArgumentException invalidWindowSize(Integer size)

Specified by:

invalidWindowSize in interface ActiveMQClientMessageBundle

noChannelToClose

public IllegalArgumentException noChannelToClose(Long id)

Specified by:

noChannelToClose in interface ActiveMQClientMessageBundle

closeListenerCannotBeNull

public IllegalArgumentException closeListenerCannotBeNull()

Specified by:

closeListenerCannotBeNull in interface ActiveMQClientMessageBundle

failListenerCannotBeNull

public IllegalArgumentException failListenerCannotBeNull()

Specified by:

failListenerCannotBeNull in interface ActiveMQClientMessageBundle

connectionExists

public IllegalArgumentException connectionExists(Object id)

Specified by:

connectionExists in interface ActiveMQClientMessageBundle

nullListener

public IllegalArgumentException nullListener()

Specified by:

nullListener in interface ActiveMQClientMessageBundle

nullHandler

public IllegalArgumentException nullHandler()

Specified by:

nullHandler in interface ActiveMQClientMessageBundle

firstNodeNull

public IllegalArgumentException firstNodeNull()

Specified by:

firstNodeNull in interface ActiveMQClientMessageBundle

secondNodeNull

public IllegalArgumentException secondNodeNull()

Specified by:

secondNodeNull in interface ActiveMQClientMessageBundle

nodeHaveDifferentNames

public IllegalArgumentException nodeHaveDifferentNames()

Specified by:

nodeHaveDifferentNames in interface ActiveMQClientMessageBundle

nodeHaveDifferentAttNumber

public IllegalArgumentException nodeHaveDifferentAttNumber()

Specified by:

nodeHaveDifferentAttNumber in interface ActiveMQClientMessageBundle

attsDontMatch

public IllegalArgumentException attsDontMatch(String name,
 String value)

Specified by:

attsDontMatch in interface ActiveMQClientMessageBundle

oneNodeHasChildren

public IllegalArgumentException oneNodeHasChildren()

Specified by:

oneNodeHasChildren in interface ActiveMQClientMessageBundle

nodeHasDifferentChildNumber

public IllegalArgumentException nodeHasDifferentChildNumber()

Specified by:

nodeHasDifferentChildNumber in interface ActiveMQClientMessageBundle

mustBeBoolean

public IllegalArgumentException mustBeBoolean(Node elem,
 String value)

Specified by:

mustBeBoolean in interface ActiveMQClientMessageBundle

mustBeDouble

public IllegalArgumentException mustBeDouble(Node elem,
 String value)

Specified by:

mustBeDouble in interface ActiveMQClientMessageBundle

mustBeInteger

public IllegalArgumentException mustBeInteger(Node elem,
 String value)

Specified by:

mustBeInteger in interface ActiveMQClientMessageBundle

mustBeLong

public IllegalArgumentException mustBeLong(Node element,
 String value)

Specified by:

mustBeLong in interface ActiveMQClientMessageBundle

errordecodingPassword

public IllegalArgumentException errordecodingPassword(Exception e)

Specified by:

errordecodingPassword in interface ActiveMQClientMessageBundle

addressIsFull

public ActiveMQAddressFullException addressIsFull(String addressName,
 int size)

Specified by:

addressIsFull in interface ActiveMQClientMessageBundle

interceptorRejectedPacket

public ActiveMQInterceptorRejectedPacketException interceptorRejectedPacket(String interceptionResult)

Specified by:

interceptorRejectedPacket in interface ActiveMQClientMessageBundle

largeMessageInterrupted

public ActiveMQLargeMessageInterruptedException largeMessageInterrupted()

Specified by:

largeMessageInterrupted in interface ActiveMQClientMessageBundle

cannotSendPacketDuringFailover

public IllegalStateException cannotSendPacketDuringFailover()

Specified by:

cannotSendPacketDuringFailover in interface ActiveMQClientMessageBundle

packetTransmissionInterrupted

public ActiveMQInterruptedException packetTransmissionInterrupted()

Specified by:

packetTransmissionInterrupted in interface ActiveMQClientMessageBundle

invalidPacket

public IllegalStateException invalidPacket(byte type)

Specified by:

invalidPacket in interface ActiveMQClientMessageBundle

failedToHandlePacket

public RuntimeException failedToHandlePacket(Exception e)

Specified by:

failedToHandlePacket in interface ActiveMQClientMessageBundle

redirected

public ActiveMQRoutingException redirected()

Specified by:

redirected in interface ActiveMQClientMessageBundle

keystoreAliasNotFound

public IllegalArgumentException keystoreAliasNotFound(String keystoreAlias,
 String keystorePath)

Specified by:

keystoreAliasNotFound in interface ActiveMQClientMessageBundle

connectionClosedOnReceiveTopology

public ActiveMQObjectClosedException connectionClosedOnReceiveTopology(DiscoveryGroup discoveryGroup)

Specified by:

connectionClosedOnReceiveTopology in interface ActiveMQClientMessageBundle

unableToCreateSession

public IllegalStateException unableToCreateSession()

Specified by:

unableToCreateSession in interface ActiveMQClientMessageBundle