Package io.keldysh.messaging

Interface MessageClient

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

ArtemisClient, InMemoryBrokerClient

public interface MessageClient
extends Closeable

Method Summary

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

Methods inherited from interface java.io.Closeable

close

Method Details

sink

default <PAYLOAD> MessageSink<PAYLOAD> sink(String outbound,
 Type payloadType)

source

default <PAYLOAD> MessageSource<PAYLOAD> source(String inbound,
 Type payloadType)

sink

default <PAYLOAD> MessageSink<PAYLOAD> sink(String outbound,
 PayloadParser<PAYLOAD> parser)

source

default <PAYLOAD> MessageSource<PAYLOAD> source(String inbound,
 PayloadParser<PAYLOAD> parser)

sink

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

source

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