Modifier | Constructor and Description |
---|---|
protected |
MessagePersister() |
Modifier and Type | Method and Description |
---|---|
static void |
clearPersisters() |
Message |
decode(ActiveMQBuffer buffer,
Message record,
CoreMessageObjectPools pools) |
Message |
decode(ActiveMQBuffer buffer,
Message record,
CoreMessageObjectPools pools,
StorageManager storageManager) |
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 MessagePersister |
getInstance() |
static Persister |
getPersister(byte id) |
static void |
registerPersister(Persister<Message> persister) |
static void |
registerProtocol(ProtocolManagerFactory manager) |
public byte getID()
Persister
public static void registerProtocol(ProtocolManagerFactory manager)
public static void clearPersisters()
public static Persister getPersister(byte id)
public static MessagePersister getInstance()
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 pools)
public Message decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools, StorageManager storageManager)
Copyright © 2021 JBoss by Red Hat. All rights reserved.