Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: INNER | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

com.newstep.solid.test.processor.performance.core

public class MessageCenter

This class is responsible for message creation and transmission from the
message producers to the message consumers (entry into the message processing
framework).

Kernel Association Association Link

Client navigability:

Supplier cardinality:

Supplier navigability:

Supplier visibility:

Kernel Association Association Link

to Class ClearingPoint

Client navigability:

Supplier cardinality:

Supplier navigability:

Supplier visibility:

Field Summary
private ClearingPoint	clearingPoint
private ThreePassProcessor	messageProcessor
private Queue	messageQueues
private long[]	numEvents

Constructor Summary
public void	MessageCenter(ThreePassProcessor messageProcessor)

Method Summary
private TestMessage	createMessage(Integer producerID, MESSAGE_TYPE messageType, Integer eventType, Long messageID)
public void	generateMessages(Integer messagesPerChannel, Boolean mixEventTypes)
public void	send(Integer numChannels, Integer whichChannel)

private ClearingPoint clearingPoint

private ThreePassProcessor messageProcessor

private Queue messageQueues

private long[] numEvents

public void MessageCenter (ThreePassProcessor messageProcessor)

messageProcessor the message processor that is used to process messages

private TestMessage createMessage (Integer producerID, MESSAGE_TYPE messageType, Integer eventType, Long messageID)

producerID the message producer by which this message is sent
messageType the encoding type of the message
eventType the event type this message creates
messageID the ID associated with this message

public void generateMessages (Integer messagesPerChannel, Boolean mixEventTypes)

Generates a random number of messages for transmission

messagesPerChannel number of messages to be created per message
producer
mixEventTypes indicates whether each message producer will only
have messages of a single type

MessageCenterException

public void send (Integer numChannels, Integer whichChannel)

Sends created messages to the message processing framework

numChannels number of message producers to use when sending
messages