Uses of Interface
org.hornetq.core.server.ServerMessage

Packages that use ServerMessage

Package	Description
org.hornetq.core.filter
org.hornetq.core.filter.impl
org.hornetq.core.paging
org.hornetq.core.paging.cursor
org.hornetq.core.paging.cursor.impl
org.hornetq.core.paging.impl
org.hornetq.core.persistence
org.hornetq.core.persistence.impl.journal
org.hornetq.core.persistence.impl.nullpm
org.hornetq.core.postoffice
org.hornetq.core.postoffice.impl
org.hornetq.core.protocol.core.impl
org.hornetq.core.server
org.hornetq.core.server.cluster
org.hornetq.core.server.cluster.impl
org.hornetq.core.server.impl
org.hornetq.core.server.management
org.hornetq.core.server.management.impl
org.hornetq.core.transaction
org.hornetq.core.transaction.impl
org.hornetq.jms.transaction
org.hornetq.spi.core.protocol

Uses of ServerMessage in org.hornetq.core.filter

Methods in org.hornetq.core.filter with parameters of type ServerMessage

Modifier and Type	Method and Description
boolean	Filter.match(ServerMessage message)

Uses of ServerMessage in org.hornetq.core.filter.impl

Methods in org.hornetq.core.filter.impl with parameters of type ServerMessage

Modifier and Type	Method and Description
boolean	FilterImpl.match(ServerMessage message)

Uses of ServerMessage in org.hornetq.core.paging

Methods in org.hornetq.core.paging that return ServerMessage

Modifier and Type	Method and Description
ServerMessage	PagedMessage.getMessage()

Methods in org.hornetq.core.paging with parameters of type ServerMessage

Modifier and Type	Method and Description
boolean	PagingStore.page(ServerMessage message, RoutingContext ctx)
boolean	PagingStore.page(ServerMessage message, RoutingContext ctx, RouteContextList listCtx)

Uses of ServerMessage in org.hornetq.core.paging.cursor

Methods in org.hornetq.core.paging.cursor that return ServerMessage

Modifier and Type	Method and Description
ServerMessage	PagedReferenceImpl.getMessage()

Uses of ServerMessage in org.hornetq.core.paging.cursor.impl

Methods in org.hornetq.core.paging.cursor.impl with parameters of type ServerMessage

Modifier and Type	Method and Description
protected boolean	PageSubscriptionImpl.match(ServerMessage message)

Uses of ServerMessage in org.hornetq.core.paging.impl

Methods in org.hornetq.core.paging.impl that return ServerMessage

Modifier and Type	Method and Description
ServerMessage	PagedMessageImpl.getMessage()

Methods in org.hornetq.core.paging.impl with parameters of type ServerMessage

Modifier and Type	Method and Description
boolean	PagingStoreImpl.page(ServerMessage message, RoutingContext ctx)
boolean	PagingStoreImpl.page(ServerMessage message, RoutingContext ctx, RouteContextList listCtx)
protected boolean	PagingStoreImpl.page(ServerMessage message, RoutingContext ctx, RouteContextList listCtx, boolean sync)

Constructors in org.hornetq.core.paging.impl with parameters of type ServerMessage

Constructor and Description
PagedMessageImpl(ServerMessage message, long[] queueIDs)
PagedMessageImpl(ServerMessage message, long[] queueIDs, long transactionID)

Uses of ServerMessage in org.hornetq.core.persistence

Methods in org.hornetq.core.persistence with parameters of type ServerMessage

Modifier and Type	Method and Description
void	StorageManager.storeMessage(ServerMessage message)
void	StorageManager.storeMessageTransactional(long txID, ServerMessage message)

Uses of ServerMessage in org.hornetq.core.persistence.impl.journal

Classes in org.hornetq.core.persistence.impl.journal that implement ServerMessage

Modifier and Type	Class and Description
class	LargeServerMessageImpl A LargeServerMessageImpl

Methods in org.hornetq.core.persistence.impl.journal that return ServerMessage

Modifier and Type	Method and Description
ServerMessage	LargeServerMessageImpl.copy()
ServerMessage	LargeServerMessageImpl.copy(long newID)

Methods in org.hornetq.core.persistence.impl.journal with parameters of type ServerMessage

Modifier and Type	Method and Description
void	LargeServerMessageImpl.setOriginalHeaders(ServerMessage other, boolean expiry)
void	JournalStorageManager.storeMessage(ServerMessage message)
void	JournalStorageManager.storeMessageTransactional(long txID, ServerMessage message)

Uses of ServerMessage in org.hornetq.core.persistence.impl.nullpm

Classes in org.hornetq.core.persistence.impl.nullpm that implement ServerMessage

Modifier and Type	Class and Description
class	NullStorageLargeServerMessage A NullStorageLargeServerMessage

Methods in org.hornetq.core.persistence.impl.nullpm with parameters of type ServerMessage

Modifier and Type	Method and Description
void	NullStorageManager.storeMessage(ServerMessage message)
void	NullStorageManager.storeMessageTransactional(long txID, ServerMessage message)

Uses of ServerMessage in org.hornetq.core.postoffice

Methods in org.hornetq.core.postoffice that return types with arguments of type ServerMessage

Modifier and Type	Method and Description
Pair<RoutingContext,ServerMessage>	PostOffice.redistribute(ServerMessage message, Queue originatingQueue, Transaction tx)

Methods in org.hornetq.core.postoffice with parameters of type ServerMessage

Modifier and Type	Method and Description
boolean	Binding.isHighAcceptPriority(ServerMessage message)
void	PostOffice.processRoute(ServerMessage message, RoutingContext context, boolean direct)
boolean	Bindings.redistribute(ServerMessage message, Queue originatingQueue, RoutingContext context)
Pair<RoutingContext,ServerMessage>	PostOffice.redistribute(ServerMessage message, Queue originatingQueue, Transaction tx)
MessageReference	PostOffice.reroute(ServerMessage message, Queue queue, Transaction tx)
void	PostOffice.route(ServerMessage message, boolean direct)
void	Bindings.route(ServerMessage message, RoutingContext context)
void	Binding.route(ServerMessage message, RoutingContext context)
void	PostOffice.route(ServerMessage message, RoutingContext context, boolean direct)
void	PostOffice.route(ServerMessage message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	PostOffice.route(ServerMessage message, Transaction tx, boolean direct)
void	PostOffice.route(ServerMessage message, Transaction tx, boolean direct, boolean rejectDuplicates)

Uses of ServerMessage in org.hornetq.core.postoffice.impl

Methods in org.hornetq.core.postoffice.impl that return types with arguments of type ServerMessage

Modifier and Type	Method and Description
Pair<RoutingContext,ServerMessage>	PostOfficeImpl.redistribute(ServerMessage message, Queue originatingQueue, Transaction tx) The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread

Methods in org.hornetq.core.postoffice.impl with parameters of type ServerMessage

Modifier and Type	Method and Description
protected void	PostOfficeImpl.cleanupInternalPropertiesBeforeRouting(ServerMessage message)
boolean	LocalQueueBinding.isHighAcceptPriority(ServerMessage message)
boolean	DivertBinding.isHighAcceptPriority(ServerMessage message)
void	PostOfficeImpl.processRoute(ServerMessage message, RoutingContext context, boolean direct)
boolean	BindingsImpl.redistribute(ServerMessage message, Queue originatingQueue, RoutingContext context)
Pair<RoutingContext,ServerMessage>	PostOfficeImpl.redistribute(ServerMessage message, Queue originatingQueue, Transaction tx) The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread
MessageReference	PostOfficeImpl.reroute(ServerMessage message, Queue queue, Transaction tx)
void	PostOfficeImpl.route(ServerMessage message, boolean direct)
void	LocalQueueBinding.route(ServerMessage message, RoutingContext context)
void	DivertBinding.route(ServerMessage message, RoutingContext context)
void	BindingsImpl.route(ServerMessage message, RoutingContext context)
void	PostOfficeImpl.route(ServerMessage message, RoutingContext context, boolean direct)
void	PostOfficeImpl.route(ServerMessage message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	PostOfficeImpl.route(ServerMessage message, Transaction tx, boolean direct)
void	PostOfficeImpl.route(ServerMessage message, Transaction tx, boolean direct, boolean rejectDuplicates)

Uses of ServerMessage in org.hornetq.core.protocol.core.impl

Methods in org.hornetq.core.protocol.core.impl with parameters of type ServerMessage

Modifier and Type	Method and Description
int	CoreSessionCallback.sendLargeMessage(ServerMessage message, long consumerID, long bodySize, int deliveryCount)
int	CoreSessionCallback.sendMessage(ServerMessage message, long consumerID, int deliveryCount)

Uses of ServerMessage in org.hornetq.core.server

Subinterfaces of ServerMessage in org.hornetq.core.server

Modifier and Type	Interface and Description
interface	LargeServerMessage A LargeMessage

Methods in org.hornetq.core.server that return ServerMessage

Modifier and Type	Method and Description
ServerMessage	ServerMessage.copy()
ServerMessage	ServerMessage.copy(long newID)
ServerMessage	MessageReference.getMessage()
ServerMessage	ServerMessage.makeCopyForExpiryOrDLA(long newID, boolean expiry)

Methods in org.hornetq.core.server with parameters of type ServerMessage

Modifier and Type	Method and Description
boolean	Queue.hasMatchingConsumer(ServerMessage message)
void	Bindable.route(ServerMessage message, RoutingContext context)
void	ServerSession.send(ServerMessage message, boolean direct)
void	ServerMessage.setOriginalHeaders(ServerMessage other, boolean expiry)

Uses of ServerMessage in org.hornetq.core.server.cluster

Methods in org.hornetq.core.server.cluster that return ServerMessage

Modifier and Type	Method and Description
ServerMessage	Transformer.transform(ServerMessage message)

Methods in org.hornetq.core.server.cluster with parameters of type ServerMessage

Modifier and Type	Method and Description
ServerMessage	Transformer.transform(ServerMessage message)

Uses of ServerMessage in org.hornetq.core.server.cluster.impl

Methods in org.hornetq.core.server.cluster.impl that return ServerMessage

Modifier and Type	Method and Description
protected ServerMessage	ClusterConnectionBridge.beforeForward(ServerMessage message)
protected ServerMessage	BridgeImpl.beforeForward(ServerMessage message)

Methods in org.hornetq.core.server.cluster.impl with parameters of type ServerMessage

Modifier and Type	Method and Description
protected ServerMessage	ClusterConnectionBridge.beforeForward(ServerMessage message)
protected ServerMessage	BridgeImpl.beforeForward(ServerMessage message)
boolean	RemoteQueueBindingImpl.isHighAcceptPriority(ServerMessage message)
void	RemoteQueueBindingImpl.route(ServerMessage message, RoutingContext context)

Uses of ServerMessage in org.hornetq.core.server.impl

Classes in org.hornetq.core.server.impl that implement ServerMessage

Modifier and Type	Class and Description
class	ServerMessageImpl A ServerMessageImpl

Methods in org.hornetq.core.server.impl that return ServerMessage

Modifier and Type	Method and Description
ServerMessage	ServerMessageImpl.copy()
ServerMessage	ServerMessageImpl.copy(long newID)
ServerMessage	MessageReferenceImpl.getMessage()
ServerMessage	ServerMessageImpl.makeCopyForExpiryOrDLA(long newID, boolean expiry)

Methods in org.hornetq.core.server.impl with parameters of type ServerMessage

Modifier and Type	Method and Description
boolean	QueueImpl.hasMatchingConsumer(ServerMessage message)
void	QueueImpl.route(ServerMessage message, RoutingContext context)
void	DivertImpl.route(ServerMessage message, RoutingContext context)
void	ServerSessionImpl.send(ServerMessage message, boolean direct)
void	ServerMessageImpl.setOriginalHeaders(ServerMessage other, boolean expiry)

Constructors in org.hornetq.core.server.impl with parameters of type ServerMessage

Constructor and Description
MessageReferenceImpl(ServerMessage message, Queue queue)

Uses of ServerMessage in org.hornetq.core.server.management

Methods in org.hornetq.core.server.management that return ServerMessage

Modifier and Type	Method and Description
ServerMessage	ManagementService.handleMessage(ServerMessage message)

Methods in org.hornetq.core.server.management with parameters of type ServerMessage

Modifier and Type	Method and Description
ServerMessage	ManagementService.handleMessage(ServerMessage message)

Uses of ServerMessage in org.hornetq.core.server.management.impl

Methods in org.hornetq.core.server.management.impl that return ServerMessage

Modifier and Type	Method and Description
ServerMessage	ManagementServiceImpl.handleMessage(ServerMessage message)

Methods in org.hornetq.core.server.management.impl with parameters of type ServerMessage

Modifier and Type	Method and Description
ServerMessage	ManagementServiceImpl.handleMessage(ServerMessage message)

Uses of ServerMessage in org.hornetq.core.transaction

Methods in org.hornetq.core.transaction with parameters of type ServerMessage

Modifier and Type	Method and Description
abstract String	TransactionDetail.decodeMessagePayload(ServerMessage msg)
abstract Map<String,Object>	TransactionDetail.decodeMessageProperties(ServerMessage msg)
abstract String	TransactionDetail.decodeMessageType(ServerMessage msg)

Uses of ServerMessage in org.hornetq.core.transaction.impl

Methods in org.hornetq.core.transaction.impl with parameters of type ServerMessage

Modifier and Type	Method and Description
String	CoreTransactionDetail.decodeMessagePayload(ServerMessage msg)
Map<String,Object>	CoreTransactionDetail.decodeMessageProperties(ServerMessage msg)
String	CoreTransactionDetail.decodeMessageType(ServerMessage msg)

Uses of ServerMessage in org.hornetq.jms.transaction

Methods in org.hornetq.jms.transaction with parameters of type ServerMessage

Modifier and Type	Method and Description
String	JMSTransactionDetail.decodeMessagePayload(ServerMessage msg)
Map<String,Object>	JMSTransactionDetail.decodeMessageProperties(ServerMessage msg)
String	JMSTransactionDetail.decodeMessageType(ServerMessage msg)

Uses of ServerMessage in org.hornetq.spi.core.protocol

Methods in org.hornetq.spi.core.protocol with parameters of type ServerMessage

Modifier and Type	Method and Description
int	SessionCallback.sendLargeMessage(ServerMessage message, long consumerID, long bodySize, int deliveryCount)
int	SessionCallback.sendMessage(ServerMessage message, long consumerID, int deliveryCount)