Modifier and Type | Field and Description |
---|---|
static byte |
ID |
Modifier | Constructor and Description |
---|---|
protected |
CoreMessagePersister() |
Modifier and Type | Method and Description |
---|---|
Message |
decode(ActiveMQBuffer buffer,
Message record,
CoreMessageObjectPools pool) |
void |
encode(ActiveMQBuffer buffer,
Message record)
Sub classes must add the first short as the protocol-id
|
int |
getEncodeSize(Message record) |
byte |
getID()
This is to be used to store the protocol-id on Messages.
|
static CoreMessagePersister |
getInstance() |
static void |
registerPersister(CoreMessagePersister newPersister)
This is a hook for testing
|
static void |
resetPersister() |
public static final byte ID
public static void registerPersister(CoreMessagePersister newPersister)
public static void resetPersister()
public static CoreMessagePersister getInstance()
public byte getID()
Persister
public int getEncodeSize(Message record)
getEncodeSize
in interface Persister<Message>
public void encode(ActiveMQBuffer buffer, Message record)
public Message decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pool)
Copyright © 2021 JBoss by Red Hat. All rights reserved.