Package org.wildfly.extension.messaging.activemq.broadcast

Class ConcurrentBroadcastCommandDispatcherFactory

java.lang.Object

org.wildfly.extension.messaging.activemq.broadcast.ConcurrentBroadcastCommandDispatcherFactory

All Implemented Interfaces:

CommandDispatcherFactory<GroupMember>, Registrar<BroadcastReceiver>, BroadcastCommandDispatcherFactory, BroadcastReceiver, BroadcastReceiverRegistrar

public class ConcurrentBroadcastCommandDispatcherFactory
extends Object
implements BroadcastCommandDispatcherFactory

A BroadcastCommandDispatcherFactory that returns the same CommandDispatcher instance for a given identifier.

Author:

Paul Ferraro

Constructor Summary

Constructors

Constructor	Description
ConcurrentBroadcastCommandDispatcherFactory(CommandDispatcherFactory<GroupMember> dispatcherFactory)

Method Summary

Modifier and Type	Method	Description
<C> CommandDispatcher<GroupMember,C>	createCommandDispatcher(Object id, C context)	Creates a new command dispatcher using the specified identifier and context.
<C> CommandDispatcher<GroupMember,C>	createCommandDispatcher(Object id, C context, ClassLoader loader)	Creates a new command dispatcher using the specified identifier and context whose marshaller will be configured from the specified class loader.
Group<GroupMember>	getGroup()	Returns the group upon which the this command dispatcher operates.
void	receive(byte[] data)	Receives the specified broadcast data.
Registration	register(BroadcastReceiver receiver)	Registers an object.

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrentBroadcastCommandDispatcherFactory

public ConcurrentBroadcastCommandDispatcherFactory(CommandDispatcherFactory<GroupMember> dispatcherFactory)

Method Details

receive

public void receive(byte[] data)

Description copied from interface: BroadcastReceiver

Receives the specified broadcast data.

Specified by:

receive in interface BroadcastReceiver

Parameters:

data - broadcast data

register

public Registration register(BroadcastReceiver receiver)

Description copied from interface: Registrar

Registers an object. The object is unregistered when the generated Registration is closed.

Specified by:

register in interface Registrar<BroadcastReceiver>

Parameters:

receiver - an object to register

Returns:

an object registration.

getGroup

public Group<GroupMember> getGroup()

Description copied from interface: CommandDispatcherFactory

Returns the group upon which the this command dispatcher operates.

Specified by:

getGroup in interface CommandDispatcherFactory<GroupMember>

Returns:

a group

createCommandDispatcher

public <C> CommandDispatcher<GroupMember,C> createCommandDispatcher(Object id,
 C context)

Description copied from interface: CommandDispatcherFactory

Creates a new command dispatcher using the specified identifier and context. The resulting CommandDispatcher will communicate with those dispatchers within the group sharing the same identifier.

Specified by:

createCommandDispatcher in interface CommandDispatcherFactory<GroupMember>

Parameters:

id - a unique identifier for this dispatcher

context - the context used for executing commands

Returns:

a new command dispatcher

createCommandDispatcher

public <C> CommandDispatcher<GroupMember,C> createCommandDispatcher(Object id,
 C context,
 ClassLoader loader)

Description copied from interface: CommandDispatcherFactory

Creates a new command dispatcher using the specified identifier and context whose marshaller will be configured from the specified class loader. The resulting CommandDispatcher will communicate with those dispatchers within the group sharing the same identifier.

Specified by:

createCommandDispatcher in interface CommandDispatcherFactory<GroupMember>

Parameters:

id - a unique identifier for this dispatcher

context - the context used for executing commands

loader - the class loader used to load commands to be dispatched.

Returns:

a new command dispatcher