public final class ContextMessageBridge extends NativeBridge implements ContextMessage
ContextMessage
.Constructor and Description |
---|
ContextMessageBridge(ContextMessage contextMessage) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
byte[] |
get()
Message payload.
|
String |
getId()
Returns an identifier of this object.
|
String |
getMessageSourceID() |
long |
getSequenceNumber() |
onError
public ContextMessageBridge(ContextMessage contextMessage)
public void close() throws Exception
close
in interface AutoCloseable
Exception
public byte[] get()
Message
get
in interface ContextMessage
get
in interface Message
public String getId()
Identifiable
getId
in interface ContextMessage
getId
in interface Identifiable
public String getMessageSourceID()
getMessageSourceID
in interface ContextMessage
public long getSequenceNumber()
getSequenceNumber
in interface ContextMessage
getSequenceNumber
in interface Numberable
Copyright © 2017 The Apache Software Foundation. All rights reserved.