rsb.transport.spread

Class AssemblyPool

java.lang.Object

rsb.transport.spread.AssemblyPool

public class AssemblyPool
extends java.lang.Object

A class that assembles fragmented messages received over spread in form of Notifications.

Author:

jwienke

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AssemblyPool.DataAndNotification

Constructor Summary

Constructors

Constructor and Description
AssemblyPool()

Method Summary

Methods

Modifier and Type	Method and Description
AssemblyPool.DataAndNotification	insert(FragmentedNotificationType.FragmentedNotification notification) Adds a new message to the assembly pool and joins the data of all notifications of the same event, if all fragments were received.

Methods inherited from class java.lang.Object

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

Constructor Detail

AssemblyPool

public AssemblyPool()

Method Detail

insert

public AssemblyPool.DataAndNotification insert(FragmentedNotificationType.FragmentedNotification notification)

Adds a new message to the assembly pool and joins the data of all notifications of the same event, if all fragments were received.

Parameters:

notification - newly received notification

Returns:

joined data or null if not event was completed with this notification