io.micronaut.nats.reactive

Class PublishState

java.lang.Object

io.micronaut.nats.reactive.PublishState

@Immutable
public class PublishState
extends java.lang.Object

Stores the state of a Nats message to be published.

Since:

1.1.0

Author:

James Kleeh

Constructor Summary

Constructors

Constructor and Description
PublishState(java.lang.String subject, byte[] body) Default constructor.

Method Summary

Modifier and Type	Method and Description
byte[]	getBody()
java.lang.String	getSubject()

Methods inherited from class java.lang.Object

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

Constructor Detail

PublishState

public PublishState(java.lang.String subject,
                    @Nullable
                    byte[] body)

Default constructor.

Parameters:

subject - The subject

body - The body

Method Detail

getSubject

public java.lang.String getSubject()

Returns:

The subject to publish the message to

getBody

@Nullable
public byte[] getBody()

Returns:

The message body