functionaltestnotification.java

来自「提供ESB 应用mule源代码 提供ESB 应用mule源代码」· Java 代码 · 共 82 行

/*
 * $Id: FunctionalTestNotification.java 12151 2008-06-24 23:36:43Z dfeist $
 * --------------------------------------------------------------------------------------
 * Copyright (c) MuleSource, Inc.  All rights reserved.  http://www.mulesource.com
 *
 * The software in this package is published under the terms of the CPAL v1.0
 * license, a copy of which has been included with this distribution in the
 * LICENSE.txt file.
 */

package org.mule.tck.functional;

import org.mule.RequestContext;
import org.mule.api.MuleEventContext;
import org.mule.api.transformer.TransformerException;
import org.mule.context.notification.CustomNotification;

/**
 * A <code>FunctionlTestNotification</code> is fired by the {@link org.mule.tck.functional.FunctionalTestComponent}
 * when it receives an event. Test cases can register a {@link org.mule.tck.functional.FunctionalTestNotificationListener}
 * with Mule to receive these notifications and make assertions about the number of messages received or the content
 * of the message.
 * <p/>
 * This Notification contains the current MuleEventContext and reply message. The resource Identifier for this event
 * is the service name that received the message.  This means you can register to listen to Notifications from a
 * selected {@link org.mule.tck.functional.FunctionalTestComponent}. i.e.
 * <code>
 * muleContext.registerListener(this, "*JmsTestCompoennt");
 * </code>
 * <p/>
 * This registration would only receive {@link org.mule.tck.functional.FunctionalTestNotification} objects
 * from components called 'MyJmsTestComponent' and 'YourJmsTestComponent' but not 'HerFileTestComponent'.
 *
 * @see org.mule.tck.functional.FunctionalTestComponent
 * @see org.mule.tck.functional.FunctionalTestNotificationListener
 * @see org.mule.api.MuleContext
 */
public class FunctionalTestNotification extends CustomNotification
{
    /** Serial version */
    private static final long serialVersionUID = -3435373745940904597L;

    public static final int EVENT_RECEIVED = -999999;

    static
    {
        registerAction("event received", EVENT_RECEIVED);
    }

    private final Object replyMessage;
    private final MuleEventContext eventContext;

    public FunctionalTestNotification(Object message, int action)
            throws TransformerException
    {
        super(message, action);
        this.replyMessage = null;
        this.eventContext = RequestContext.getEventContext();
        resourceIdentifier = eventContext.getService().getName();

    }

    public FunctionalTestNotification(MuleEventContext context, Object replyMessage, int action)
            throws TransformerException
    {
        super(context.transformMessage(), action);
        resourceIdentifier = context.getService().getName();
        this.replyMessage = replyMessage;
        this.eventContext = context;
    }

    public Object getReplyMessage()
    {
        return replyMessage;
    }

    public MuleEventContext getEventContext()
    {
        return eventContext;
    }
}