org.iqual.chaplin.msg
Class MessagingHelper

java.lang.Object
  org.iqual.chaplin.msg.MessagingHelper

public class MessagingHelper
extends Object

This class makes messaging in Chaplin easier by providing a set of utility static methods.

Since:

Jun 12, 2009 5:26:33 PM

Author:

Zbynek Slajchrt

Constructor Summary

MessagingHelper()

Method Summary

static boolean	canBeInvoked(List<MessageReceiver> rcvs, Object source, String classifier, String methodName, Class[] argTypes, Class returnType)
static boolean	canBeInvoked(MessageReceiver rcv, Object source, String classifier, String methodName, Class[] argTypes, Class returnType) Decides whether the context handler can invoke the specified method.
static Object	getProperty(List<MessageReceiver> rcvs, String classifier, String fieldName, Class fieldTypeClass, Object source)
static Object	getProperty(List<MessageReceiver> rcvs, String classifier, String fieldName, Class fieldTypeClass, Object source, FromAnnotContent fromAnnot)
static Object	getProperty(MessageReceiver rcv, String classifier, String fieldName, Class fieldTypeClass, Object source)
static Object	getProperty(MessageReceiver rcv, String classifier, String fieldName, Class fieldTypeClass, Object source, FromAnnotContent fromAnnot) Convert the request for getting a value to the GET message and let the context handler to handle this message.
static boolean	hasProperty(List<MessageReceiver> rcvs, String classifier, String fieldName, Class fieldTypeClass)
static boolean	hasProperty(MessageReceiver rcv, String classifier, String fieldName, Class fieldTypeClass) Convert the request for setting a value to the tracing message and let the context handler to handle this message.
static Object	invoke(List<MessageReceiver> rcvs, Object source, String classifier, String methodName, Class[] argTypes, Class returnType, long minOccurs, long maxOccurs, AggregationType aggType, FromAnnotContent fromAnnot, Object[] args)
static Object	mergeReplies(Message msg, List replies, boolean isTrace)
static void	populateMessageFromFromAnnot(Message message, FromAnnotContent fromAnnot)
static Object	processMessage(Message message, List<MessageReceiver> rcvs) Send the message to the context handler.
static Object	processMessage(Message message, MessageReceiver rcv)
static void	publishMessage(String messageName, String context, MessageReceiver receiver) Publish the message to the receiver.
static void	publishMessage(String messageName, String context, MessageReceiver receiver, Class[] argTypes, Object[] args)
static void	setProperty(List<MessageReceiver> rcvs, String contextName, String fieldName, Class fieldTypeClass, Object value, Object source)
static void	setProperty(MessageReceiver rcv, String classifier, String fieldName, Class fieldTypeClass, Object value, Object source) Convert the request for setting a value to the SET message and let the context handler to handle this message.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessagingHelper

public MessagingHelper()

Method Detail

getProperty

public static Object getProperty(MessageReceiver rcv,
                                 String classifier,
                                 String fieldName,
                                 Class fieldTypeClass,
                                 Object source)
                          throws Throwable

Throws:

Throwable

getProperty

public static Object getProperty(MessageReceiver rcv,
                                 String classifier,
                                 String fieldName,
                                 Class fieldTypeClass,
                                 Object source,
                                 FromAnnotContent fromAnnot)
                          throws Throwable

Convert the request for getting a value to the GET message and let the context handler to handle this message.

Throws:

Throwable

getProperty

public static Object getProperty(List<MessageReceiver> rcvs,
                                 String classifier,
                                 String fieldName,
                                 Class fieldTypeClass,
                                 Object source)
                          throws Throwable

Throws:

Throwable

getProperty

public static Object getProperty(List<MessageReceiver> rcvs,
                                 String classifier,
                                 String fieldName,
                                 Class fieldTypeClass,
                                 Object source,
                                 FromAnnotContent fromAnnot)
                          throws Throwable

Throws:

Throwable

populateMessageFromFromAnnot

public static void populateMessageFromFromAnnot(Message message,
                                                FromAnnotContent fromAnnot)
                                         throws Exception

Throws:

Exception

setProperty

public static void setProperty(MessageReceiver rcv,
                               String classifier,
                               String fieldName,
                               Class fieldTypeClass,
                               Object value,
                               Object source)
                        throws Throwable

Convert the request for setting a value to the SET message and let the context handler to handle this message.

Throws:

Throwable

setProperty

public static void setProperty(List<MessageReceiver> rcvs,
                               String contextName,
                               String fieldName,
                               Class fieldTypeClass,
                               Object value,
                               Object source)
                        throws Throwable

Throws:

Throwable

hasProperty

public static boolean hasProperty(MessageReceiver rcv,
                                  String classifier,
                                  String fieldName,
                                  Class fieldTypeClass)
                           throws Throwable

Convert the request for setting a value to the tracing message and let the context handler to handle this message.

Throws:

Throwable

hasProperty

public static boolean hasProperty(List<MessageReceiver> rcvs,
                                  String classifier,
                                  String fieldName,
                                  Class fieldTypeClass)
                           throws Throwable

Throws:

Throwable

canBeInvoked

public static boolean canBeInvoked(MessageReceiver rcv,
                                   Object source,
                                   String classifier,
                                   String methodName,
                                   Class[] argTypes,
                                   Class returnType)

Decides whether the context handler can invoke the specified method.

Parameters:

source - the component which posts the request

methodName -

argTypes -

Returns:

canBeInvoked

public static boolean canBeInvoked(List<MessageReceiver> rcvs,
                                   Object source,
                                   String classifier,
                                   String methodName,
                                   Class[] argTypes,
                                   Class returnType)

invoke

public static Object invoke(List<MessageReceiver> rcvs,
                            Object source,
                            String classifier,
                            String methodName,
                            Class[] argTypes,
                            Class returnType,
                            long minOccurs,
                            long maxOccurs,
                            AggregationType aggType,
                            FromAnnotContent fromAnnot,
                            Object[] args)
                     throws Throwable

Throws:

Throwable

processMessage

public static Object processMessage(Message message,
                                    MessageReceiver rcv)
                             throws Throwable

Throws:

Throwable

processMessage

public static Object processMessage(Message message,
                                    List<MessageReceiver> rcvs)
                             throws Throwable

Send the message to the context handler. If there are more results the last one overrides all previous results.

Throws:

Throwable

mergeReplies

public static Object mergeReplies(Message msg,
                                  List replies,
                                  boolean isTrace)
                           throws Throwable

Throws:

Throwable

publishMessage

public static void publishMessage(String messageName,
                                  String context,
                                  MessageReceiver receiver)
                           throws Throwable

Publish the message to the receiver. There is no constraint on the number of receptions.

Parameters:

messageName -

context - the context (namespace, package, interface, class)

receiver -

Throws:

Throwable

publishMessage

public static void publishMessage(String messageName,
                                  String context,
                                  MessageReceiver receiver,
                                  Class[] argTypes,
                                  Object[] args)
                           throws Throwable

Throws:

Throwable