Package io.keldysh.messaging.artemis

Class ArtemisClient

java.lang.Object

io.keldysh.messaging.artemis.ArtemisClient

All Implemented Interfaces:

MessageClient, Closeable, AutoCloseable

public class ArtemisClient
extends Object
implements MessageClient

Constructor Summary

Constructors

Constructor	Description
ArtemisClient(ArtemisConfigurationProperties configurationProperties)
ArtemisClient(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator, ArtemisConfigurationProperties configurationProperties)

Method Summary

Modifier and Type	Method	Description
void	close()
<PAYLOAD> MessageSink<PAYLOAD>	sink(String outbound, PayloadParser.Writer<PAYLOAD> writer)
<PAYLOAD> MessageSource<PAYLOAD>	source(String inbound, PayloadParser.Reader<PAYLOAD> reader)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.keldysh.messaging.MessageClient

sink, sink, source, source

Constructor Details

ArtemisClient

public ArtemisClient(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator,
 ArtemisConfigurationProperties configurationProperties)
              throws Exception

Throws:

Exception

ArtemisClient

public ArtemisClient(ArtemisConfigurationProperties configurationProperties)
              throws Exception

Throws:

Exception

Method Details

sink

public <PAYLOAD> MessageSink<PAYLOAD> sink(String outbound,
 PayloadParser.Writer<PAYLOAD> writer)

Specified by:

sink in interface MessageClient

source

public <PAYLOAD> MessageSource<PAYLOAD> source(String inbound,
 PayloadParser.Reader<PAYLOAD> reader)

Specified by:

source in interface MessageClient

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable