public class QueueSendTag extends CommonTagSupport
●形式:<og:queueSend queueType="mq" mqQueueName="queue01" message="テキスト" /> ●body:あり(EVAL_BODY_BUFFERED:BODYを評価し、{@XXXX} を解析します) ●Tag定義: <og:queueSend jmsServer 【TAG】JMSサーバの接続先を指定します。JNDI名で指定します。(初期値:jms/Default) ※別途コンテキストファイルに接続情報が記載されている必要があります。 queueType 【TAG】タイプ(MQ,SQS)を指定します。 mqTransacted 【TAG】トランザクション確認応答フラグを指定します。(MQ用)(初期値:false) true:トランザクション確認応答 false: 確認応答タイプに指定した確認応答 mqAcknowledgeMode 【TAG】確認応答タイプを指定します。(MQ用)(初期値:1) 1:AUTO_ACKNOWLEDTE(自動応答:1回の配信を保障) 2:CLIENT_ACKNOWLEDE(クライアント応答) 3:DUPS_OK_ACKNOWLEDTE(自動応答:複数回の配信可能性あり) mqQueueName 【TAG】キュー名を指定します。(MQ用) message 【TAG】送信するメッセージを指定します。 sqsFifoGroupId 【TAG】グループIDを指定します。(SQSのFIFOキュータイプ用) sqsFifoDedupliId 【TAG】重複排除IDを指定します。(SQSのFIFOキュータイプ用) ● 使用例 ・<og:queueSend queueType="mq" mqQueueName="queue01" message="送信テキスト" /> ・<og:queueSend queueType="mq" mqQueueName="queue01" /> 送信テキスト </og:queueSend> ・<og:queueSend queueType="sqs" sqsGroupId="group01" message="送信テキスト" />
5.10.14.0 (2019/08/01) 新規作成 |
コンストラクタと説明 |
---|
QueueSendTag() |
修飾子とタイプ | メソッドと説明 |
---|---|
int |
doAfterBody()
Taglibのタグ本体を処理する doAfterBody() をオーバーライドします。
|
int |
doEndTag()
Taglibの終了タグが見つかった時に処理する doEndTag() をオーバーライドします。
|
int |
doStartTag()
Taglibの開始タグが見つかった時に処理する doStartTag() をオーバライドします。
|
protected void |
release2()
タグリブオブジェクトをリリースします。
|
void |
setJmsServer(java.lang.String server)
【TAG】メッセージサーバのURLを指定します。
|
void |
setMessage(java.lang.String mess)
【TAG】メッセージを指定します。
|
void |
setMqAcknowledgeMode(java.lang.String mode)
【TAG】MQ確認応答タイプを指定します。
|
void |
setMqQueueName(java.lang.String qName)
【TAG】MQキュー名を指定します。
|
void |
setMqTransacted(java.lang.String flg)
【TAG】MQトランザクション処理判定を指定します。
|
void |
setQueueType(java.lang.String qType)
【TAG】キューのタイプを指定します。
|
void |
setSqsFifoDedupliId(java.lang.String sqsFifoDid)
【TAG】 SQSのFIFOタイプキューの重複排除IDを指定します。
|
void |
setSqsFifoGroupId(java.lang.String sqsGid)
【TAG】SQSのFIFOタイプキューのグループIDを指定します。
|
java.lang.String |
toString()
このオブジェクトの文字列表現を返します。
|
add, add, addEventColumn, addEventColumn, check, check, commitTableObject, debugPrint, doCatch, doFinally, get, getApplicationInfo, getAttributes, getBodyRawString, getBodyString, getContextAttribute, getContextPath, getCookie, getCSVParameter, getDataCondition, getDateFormat, getDBColumn, getDBFunctionName, getDocumentLink, getGUIInfo, getGUIInfoAttri, getHostName, getLabel, getLabelInterface, getLanguage, getLASTAttri, getLongLabel, getMsglbl, getNVLAttri, getObject, getParameterNames, getParameterRows, getRequest, getRequestAttribute, getRequestCacheData, getRequestMethod, getRequestParameter, getRequestParameterValues, getRequestValue, getRequestValue, getRequestValues, getReservedParameter, getReservedValue, getResource, getSanitizedBodyString, getScope, getSessionAttribute, getTagName, getUser, getUserEditInfo, getUserInfo, isAjaxSubmitRequest, isDebug, isNoTransitionRequest, isNull, jspPrint, removeContextAttribute, removeObject, removeRequestAttribute, removeSessionAttribute, set, setAjaxSubmitRequest, setCaseKey, setCaseNN, setCaseNull, setCaseVal, setContextAttribute, setCookie, setDebug, setLanguage, setLbl, setNoTransitionRequest, setObject, setObject, setParameterNames, setParameterRows, setRequestAttribute, setRequestCacheData, setScope, setSessionAttribute, setUserInfo, startQueryTransaction, sys, sysBool, sysInt, useMainTrans, useQuotCheck, useTag, useXssCheck
public QueueSendTag()
protected void release2()
release2
クラス内 CommonTagSupport
public int doStartTag()
doStartTag
クラス内 CommonTagSupport
public int doAfterBody()
doAfterBody
クラス内 CommonTagSupport
public int doEndTag()
doEndTag
クラス内 CommonTagSupport
5.10.15.0 (2019/08/30)アクセスキー修正 |
public void setJmsServer(java.lang.String server)
server
- JMSサーバの接続先送信先のメッセージサーバのURLを指定します。
public void setMqTransacted(java.lang.String flg)
flg
- トランザクション処理フラグMQトランザクションの処理判定を指定します。 true:受信側でコミット、ロールバックのトランザクション応答を行います。 ※trueの場合は、MQ確認応答タイプは無効になります。 false:受信側はMQ確認応答タイプに指定した値によって、確認応答を行います。
public void setMqAcknowledgeMode(java.lang.String mode)
mode
- 確認応答モードMQ確認応答タイプを指定します。 ※MQトランザクション処理判定にはfalseを指定して下さい。 1:AUTO_ACKNOWLEDGE メッセージの配信の通知をjmsサーバーが自動的に処理するモードです。 1回だけの配信を保障します。 2:CLIENT_ACKNOWLEDGE 確認応答を受信側が行うモードです。 受信側に確認応答の実行が必要です。 3:DUPS_OK_ACKNOWLEDGE AUTO_AKNOWLEDGEと同様にjmsサーバーが自動的に処理を行います。 複数回配信される可能性があります。(処理が軽い事がメリットです。 基本的にはAUTO_ACKNOWLEDGEを推奨します。)
public void setMqQueueName(java.lang.String qName)
qName
- MQキュー名MQタイプのキューを利用時、 メッセージを格納するキュー名を指定します。
public void setMessage(java.lang.String mess)
mess
- メッセージ送信するメッセージを指定します。
public void setQueueType(java.lang.String qType)
qType
- キュータイプ利用するメッセージサーバのタイプを指定します。 下記のタイプが利用可能です。 mq : ActiveQueue or AmazonMQ sqs:AmazonSQS
public void setSqsFifoGroupId(java.lang.String sqsGid)
sqsGid
- SQSFIFOタイプキューのグループIDawsのSQSのFIFOタイプキューを利用時、 グループIDを指定します。 同一の値内で、FIFOの配信順序が保障されます。
public void setSqsFifoDedupliId(java.lang.String sqsFifoDid)
sqsFifoDid
- SQSFIFOタイプキューの重複禁止IDawsのSQSのFIFOタイプキューを利用時、 重複排除IDを指定します。 5分間同一の値が送信された場合、キューに格納しない機能です。 aws側の設定で、メッセージを暗号化した値を、自動設定することも可能です。
public java.lang.String toString()
toString
クラス内 CommonTagSupport
Webアプリケーションフレームワーク openGionCopyright (c) 2009 The openGion Project.