Package io.keldysh.messaging.in_memory

Class InMemoryBroker

java.lang.Object

io.keldysh.messaging.in_memory.InMemoryBroker

public class InMemoryBroker
extends Object

Constructor Summary

Constructors

Constructor	Description
InMemoryBroker()

Method Summary

Modifier and Type	Method	Description
void	createMulticast(String outboundName)	Equal to createMulticast(String, String), with equal identifier for inbound and outbound.
void	createMulticast(String inboundName, String outboundName)	If not already existing, create a new inbound address to receive published messages, and route received messages to any consumer subscribed to provided outbound queue.

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryBroker

public InMemoryBroker()

Method Details

createMulticast

public void createMulticast(String outboundName)

Equal to createMulticast(String, String), with equal identifier for inbound and outbound.

Parameters:

outboundName - - Identifier for both inbound address to published and outbound queue to receives messages.

createMulticast

public void createMulticast(String inboundName,
 String outboundName)

If not already existing, create a new inbound address to receive published messages, and route received messages to any consumer subscribed to provided outbound queue. Multiple subscribers to the same outbound are not supported.

Parameters:

inboundName - - Identifier of the inbound address, to publish messages to the broker.

outboundName - - Identifier of the outbound queue, to receive messages from the broker.