package requestquote;

import org.apache.beehive.controls.api.bean.ControlExtension;

/*

 * カスタム パブリッシュ コントロール。  

 */

@ControlExtension

@com.bea.control.PublishControl.ClassPublish(channelName = "/deadletter/rawData")

public interface MBPublish extends com.bea.control.PublishControl {

	@com.bea.control.PublishControl.MethodPublish(body = "{value}")

	void publish(com.bea.data.RawData value);

	@com.bea.control.PublishControl.MethodPublish(metadata = "{metadata}", body = "{value}")

	void publishWithMetadata(org.apache.xmlbeans.XmlObject metadata,

			com.bea.data.RawData value);

	static final long serialVersionUID = 1L;

	public MBPublish create();

}

package com.bea.control;

import com.bea.wli.control.dynamicProperties.PublishControlPropertiesDocument;
import org.w3c.dom.Element;
import weblogic.jws.control.Control;

/**
 * メッセージ ブローカ パブリッシュ コントロールの基本インタフェース
 */

public interface PublishControl extends Control {

    /**
     * 次回のパブリッシュ操作で使用するためにメッセージ ヘッダを一時的に設定する 
     * @param headers headers to set
     */

    void setOutputHeaders(Element[] headers);

    /**
     * コントロールの動的なプロパティを設定する 
     * @param props  コントロールの動的なプロパティ
     */

     void setProperties(PublishControlPropertiesDocument props);
    /**
     * コントロールの動的なプロパティを設定する
     * @return コントロールの現在のプロパティ
     */

     PublishControlPropertiesDocument getProperties();
}

<PublishControlProperties>
    <channel-name>potopic</channel-name>
    <message-metadata>
        <custom-header>ACME Corp</custom-header>
    <message-metadata>
</PublishControlProperties>

<xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema"
targetNamespace="http://www.bea.com/wli/control/dynamicProperties"
xmlns="http://www.bea.com/wli/control/dynamicProperties"
elementFormDefault="qualified">
    <xs:element name="PublishControlProperties">
        <xs:complexType>
            <xs:sequence>
                <xs:element name="channel-name" type="xs:string" 
                            minOccurs="0" maxOccurs="1" />
                <xs:element name="message-metadata" type="header" 
                            minOccurs="0" maxOccurs="1" />
            </xs:sequence>
        </xs:complexType>
    </xs:element>

<!-- 以下の複合型は、XML のコンテンツにおける任意のシーケンスを表す -->

    <xs:complexType name="header">
        <xs:sequence>
            <xs:any namespace="##other" minOccurs="0" 
                    maxOccurs="unbounded" processContents="lax" />
        </xs:sequence>
    </xs:complexType>
</xs:schema>

/*
 * @com.bea.control.PublishControl.ClassPublish channel-name="/controls/potopic" 
 */

public interface MBPublish extends com.bea.control.PublishControl{
    /**
     * @com.bea.control.PublishControl.MethodPublish
     *      message-metadata="<custom-header>ACME Corp</custom-header>"
     *      message-body="{myMsgToSend}"
     */

    void publishPO(XmlObject myMsgToSend);
}

/*
 * org.apache.beehive.controls.api.bean.Control 
 */
private MyPublishControl pubCtrl;

// メッセージをパブリッシュする 
void sendIt(XmlObject myMsgToSend) {
    pubCtrl.publishPO(myMsgToSend);
}

import com.bea.control.SubscriptionControl;  
import com.bea.data.RawData; 
import com.bea.xml.XmlObject; 

package requestquote;

import com.bea.control.SubscriptionControl;

import org.apache.beehive.controls.api.bean.ControlExtension;

import org.apache.beehive.controls.api.events.EventSet;

/*

 * カスタム サブスクリプション コントロール。  

 */

@ControlExtension

@SubscriptionControl.ClassSubscription(channelName = "/deadletter/string")

public interface MBSubscription extends com.bea.control.SubscriptionControl {

	@EventSet

	interface Callback {

		@SubscriptionControl.SubscriptionCallback(body = "{message}")

		void onMessage(String message);

	}

	static final long serialVersionUID = 1L;

	public MBSubscription create();

}

package com.bea.control;

import weblogic.jws.control.Control;

/**
 * メッセージ ブローカ サブスクリプション コントロールの基本インタフェース
 */

public interface SubscriptionControl extends Control
{

/**
     * コントロールでメッセージ ブローカをサブスクライブする。サブスクリプションで
     * フィルタ式を使用する場合、デフォルトのフィルタ値が 
     * 使用される。デフォルトのフィルタ値がアノテーションで定義されていない場合は、
     * <tt>null</tt> フィルタ値が使用される。これは
     * フィルタ結果がコールバックをトリガすることを意味する。
     */

    void subscribe();

    /**
     * コントロールをメッセージ ブローカからアンサブスクライブする。
     * 以降のイベント (メッセージ) のコントロールへの配信が停止される。

    void unsubscribe();
    
    interface Callback {
        /**

         * ユーザ定義のコールバックを実装するために使用される内部的なコールバック メソッド。
         * JPD ではこのコールバック メソッドを実装できない。
         *
         * @param msg サブスクリプションをトリガしたメッセージ
         * @throws Exception
         *
        void _internalCallback(Object msg) throws Exception;
         */
    }
}

package requestquote;

import org.apache.beehive.controls.api.bean.ControlExtension;

import org.apache.beehive.controls.api.events.EventSet;

import org.apache.xmlbeans.XmlObject;

/*

 * カスタム サブスクリプション コントロール。  

 */

@ControlExtension

@SubscriptionControl.ClassSubscription(channelName = "/deadletter/xml")

public interface SubscriptionControl extends

		com.bea.control.SubscriptionControl {

	@SubscriptionControl.MethodSubscription(filterValueMatch = "{value}")

	void subscribeWithFilterValue(String value);

	@EventSet

	interface Callback {

		@SubscriptionControl.SubscriptionCallback(body = "{message}", metadata = "{metadata}")

		void onMessage(XmlObject message, XmlObject metadata);

	}

	static final long serialVersionUID = 1L;

	public SubscriptionControl create();

}