Package org.nuxeo.ecm.core.bulk.message

Class DataBucket

java.lang.Object

org.nuxeo.ecm.core.bulk.message.DataBucket

All Implemented Interfaces:

Serializable

public class DataBucket
extends Object
implements Serializable

A generic message that contains a commandId and a number of processed docs

Since:

10.2

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected String	commandId
protected long	count
protected byte[]	data
protected byte[]	footer
protected byte[]	header

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DataBucket()
	DataBucket(String commandId, long count, byte[] data)
	DataBucket(String commandId, long count, byte[] data, byte[] header, byte[] footer)
	DataBucket(String commandId, long count, String data)
	DataBucket(String commandId, long count, String data, String header, String footer)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getCommandId()
long	getCount()
byte[]	getData()
String	getDataAsString()
byte[]	getFooter()
String	getFooterAsString()
byte[]	getHeader()
String	getHeaderAsString()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

commandId

protected String commandId

count

protected long count

data

protected byte[] data

header

protected byte[] header

footer

protected byte[] footer

Constructor Detail

DataBucket

protected DataBucket()

DataBucket

public DataBucket(String commandId,
                  long count,
                  String data)

DataBucket

public DataBucket(String commandId,
                  long count,
                  byte[] data)

DataBucket

public DataBucket(String commandId,
                  long count,
                  String data,
                  String header,
                  String footer)

DataBucket

public DataBucket(String commandId,
                  long count,
                  byte[] data,
                  byte[] header,
                  byte[] footer)

Method Detail

getCommandId

public String getCommandId()

getCount

public long getCount()

getData

public byte[] getData()

getHeader

public byte[] getHeader()

getFooter

public byte[] getFooter()

getDataAsString

public String getDataAsString()

getHeaderAsString

public String getHeaderAsString()

getFooterAsString

public String getFooterAsString()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object