ibspan.tss.agents.pma.learning
Class HistorySubscriber

java.lang.Object
  jade.core.behaviours.Behaviour
      jade.core.behaviours.CompositeBehaviour
          jade.core.behaviours.SerialBehaviour
              jade.core.behaviours.FSMBehaviour
                  jade.proto.SubscriptionInitiator
                      ibspan.tss.agents.pma.learning.HistorySubscriber

All Implemented Interfaces:

Serializable

public class HistorySubscriber
extends SubscriptionInitiator

This is simple behaviour resonsible subscribing for new events at SessionHandlingAgent and receiving notification about them. All notifications are put into SynchronizedStore object passed as an argument in constructor.

Size of a single pack of events this behaviour subscribes for is defined in ProfileManagingAgent.conf_NUMBER_OF_EVENTS_IN_PACK constant. Maciej Gawinecki

See Also:

SessionHandlingAgent, SynchronizedStore, Serialized Form

Nested Class Summary

protected static interface

Initiator.ProtocolSession

Nested classes/interfaces inherited from class jade.core.behaviours.Behaviour

Behaviour.RunnableChangedEvent

Field Summary

protected String	ALL_INITIATIONS_K
protected static String	CHECK_IN_SEQ
protected static String	CHECK_SESSIONS
protected static String	DUMMY_FINAL
protected static String	HANDLE_FAILURE
protected static String	HANDLE_NOT_UNDERSTOOD
protected static String	HANDLE_OUT_OF_SEQ
protected String	INITIATION_K
protected static String	PREPARE_INITIATIONS
protected static String	RECEIVE_REPLY
protected String	REPLY_K
protected MsgReceiver	replyReceiver
protected MessageTemplate	replyTemplate
protected static String	SEND_INITIATIONS
protected Map	sessions

Fields inherited from class jade.proto.SubscriptionInitiator

ALL_RESPONSES_KEY, ALL_SUBSCRIPTIONS_KEY, REPLY_KEY, SUBSCRIPTION_KEY

Fields inherited from class jade.core.behaviours.FSMBehaviour

currentName, lastStates, previousName

Fields inherited from class jade.core.behaviours.CompositeBehaviour

currentExecuted

Fields inherited from class jade.core.behaviours.Behaviour

myEvent, NOTIFY_DOWN, NOTIFY_UP, parent, STATE_BLOCKED, STATE_READY, STATE_RUNNING

Constructor Summary

HistorySubscriber(Agent a, SynchronizedStore store)
Constructs HistorySubscriber objects.

Method Summary

protected void	adjustReplyTemplate(ACLMessage arg0)
protected String	createConvId(Vector arg0)
protected void	handleFailure(ACLMessage failure)
protected void	handleInform(ACLMessage inform)
protected void	handleNotUnderstood(ACLMessage arg0)
protected void	handleOutOfSequence(ACLMessage arg0)
protected void	handleRefuse(ACLMessage refuse)
void	onStart()
protected Vector	prepareSubscriptions(ACLMessage subscription)
void	registerHandleFailure(Behaviour arg0)
void	registerHandleNotUnderstood(Behaviour arg0)
void	registerHandleOutOfSequence(Behaviour arg0)
protected void	registerPrepareInitiations(Behaviour arg0)
void	reset()
void	reset(ACLMessage arg0)
protected void	sendInitiations(Vector arg0)
void	setDataStore(DataStore arg0)

Methods inherited from class jade.proto.SubscriptionInitiator

cancel, cancellationCompleted, checkInSequence, checkSessions, fillCancelContent, getSession, getToBeReset, handleAgree, handleAllResponses, initializeDataStore, prepareInitiations, registerHandleAgree, registerHandleAllResponses, registerHandleInform, registerHandleRefuse, registerPrepareSubscriptions, reinit

Methods inherited from class jade.core.behaviours.FSMBehaviour

checkTermination, deregisterState, forceTransitionTo, getChildren, getCurrent, getLastExitValue, getName, getPrevious, getState, handleInconsistentFSM, handleStateEntered, onEnd, registerDefaultTransition, registerDefaultTransition, registerFirstState, registerLastState, registerState, registerTransition, registerTransition, resetStates, scheduleFirst, scheduleNext

Methods inherited from class jade.core.behaviours.SerialBehaviour

handle

Methods inherited from class jade.core.behaviours.CompositeBehaviour

action, block, done, registerAsChild, resetChildren, restart, setAgent

Methods inherited from class jade.core.behaviours.Behaviour

actionWrapper, block, getBehaviourName, getDataStore, getExecutionState, getParent, isRunnable, root, setBehaviourName, setExecutionState

Methods inherited from class java.lang.Object

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

Field Detail

INITIATION_K

protected final String INITIATION_K

ALL_INITIATIONS_K

protected final String ALL_INITIATIONS_K

REPLY_K

protected final String REPLY_K

PREPARE_INITIATIONS

protected static final String PREPARE_INITIATIONS

See Also:

Constant Field Values

SEND_INITIATIONS

protected static final String SEND_INITIATIONS

See Also:

Constant Field Values

RECEIVE_REPLY

protected static final String RECEIVE_REPLY

See Also:

Constant Field Values

CHECK_IN_SEQ

protected static final String CHECK_IN_SEQ

See Also:

Constant Field Values

HANDLE_NOT_UNDERSTOOD

protected static final String HANDLE_NOT_UNDERSTOOD

See Also:

Constant Field Values

HANDLE_FAILURE

protected static final String HANDLE_FAILURE

See Also:

Constant Field Values

HANDLE_OUT_OF_SEQ

protected static final String HANDLE_OUT_OF_SEQ

See Also:

Constant Field Values

CHECK_SESSIONS

protected static final String CHECK_SESSIONS

See Also:

Constant Field Values

DUMMY_FINAL

protected static final String DUMMY_FINAL

See Also:

Constant Field Values

sessions

protected Map sessions

replyReceiver

protected MsgReceiver replyReceiver

replyTemplate

protected MessageTemplate replyTemplate

Constructor Detail

HistorySubscriber

public HistorySubscriber(Agent a,
                         SynchronizedStore store)

Constructs HistorySubscriber objects.

Parameters:

a - is the agent this behaviour belongs to.

store - is store for passing received packs of events to any waiting for them, e.g. to ContinousLearning behaviour.

See Also:

ContinuousLearning

Method Detail

handleInform

protected void handleInform(ACLMessage inform)

Overrides:

handleInform in class SubscriptionInitiator

handleRefuse

protected void handleRefuse(ACLMessage refuse)

Overrides:

handleRefuse in class SubscriptionInitiator

handleFailure

protected void handleFailure(ACLMessage failure)

prepareSubscriptions

protected Vector prepareSubscriptions(ACLMessage subscription)

Overrides:

prepareSubscriptions in class SubscriptionInitiator

sendInitiations

protected void sendInitiations(Vector arg0)

handleNotUnderstood

protected void handleNotUnderstood(ACLMessage arg0)

handleOutOfSequence

protected void handleOutOfSequence(ACLMessage arg0)

registerPrepareInitiations

protected void registerPrepareInitiations(Behaviour arg0)

registerHandleNotUnderstood

public void registerHandleNotUnderstood(Behaviour arg0)

registerHandleFailure

public void registerHandleFailure(Behaviour arg0)

registerHandleOutOfSequence

public void registerHandleOutOfSequence(Behaviour arg0)

reset

public void reset()

Overrides:

reset in class FSMBehaviour

reset

public void reset(ACLMessage arg0)

onStart

public void onStart()

Overrides:

onStart in class Behaviour

setDataStore

public void setDataStore(DataStore arg0)

Overrides:

setDataStore in class Behaviour

createConvId

protected String createConvId(Vector arg0)

adjustReplyTemplate

protected void adjustReplyTemplate(ACLMessage arg0)