org.xmlBlaster.client.queuemsg
Class ClientEntryFactory

java.lang.Object
  org.xmlBlaster.client.queuemsg.ClientEntryFactory

All Implemented Interfaces:

I_EntryFactory

public class ClientEntryFactory

extends java.lang.Object

implements I_EntryFactory

The implementation of the interface which can be used to convert an object which implements the interface I_Entry to an Object and back. This is useful for example if you want to store such entries in persistent storage like a database or a file system. It might however be used even for other purposes.

Author:

michele@laghi.eu, xmlBlaster@marcelruff.info

Constructor Summary

ClientEntryFactory()

Method Summary

I_Entry	createEntry(int priority, long timestamp, java.lang.String type, boolean persistent, long sizeInBytes, java.io.InputStream is, StorageId storageId) Parses back the raw data to a I_Entry (deserializing)
java.lang.Object	getProperties() Access the current Parser configuration
void	initialize(Global glob) Is called after the instance is created.
void	setProperties(java.lang.Object userData) Allows to overwrite properties which where passed on initialize() The properties which support hot configuration are depending on the used implementation
byte[]	toBlob(I_Entry entry) Parses the specified entry to a byte array (serializing).

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientEntryFactory

public ClientEntryFactory()

Method Detail

toBlob

public byte[] toBlob(I_Entry entry)
              throws XmlBlasterException

Parses the specified entry to a byte array (serializing).

Specified by:

toBlob in interface I_EntryFactory

Throws:

XmlBlasterException

createEntry

public I_Entry createEntry(int priority,
                           long timestamp,
                           java.lang.String type,
                           boolean persistent,
                           long sizeInBytes,
                           java.io.InputStream is,
                           StorageId storageId)
                    throws XmlBlasterException

Parses back the raw data to a I_Entry (deserializing)

Specified by:

createEntry in interface I_EntryFactory

Parameters:

type - see ENTRY_TYPE_MSG etc.

priority - The priority of the entry (the queues first sort criteria)

timestamp - The queues second sort criteria

persistent - true: the entry is persistent, false: the entry is swapped from cache (no more RAM memory)

sizeInBytes - The approximate, immutable size that the entry occupies in RAM, this can be totally different to the size the entry occupies on storage

storageId - A unique identifier of the queue

Throws:

XmlBlasterException

initialize

public void initialize(Global glob)

Is called after the instance is created.

Specified by:

initialize in interface I_EntryFactory

setProperties

public void setProperties(java.lang.Object userData)

Allows to overwrite properties which where passed on initialize() The properties which support hot configuration are depending on the used implementation

Specified by:

setProperties in interface I_EntryFactory

getProperties

public java.lang.Object getProperties()

Access the current Parser configuration

Specified by:

getProperties in interface I_EntryFactory