001/* 002 * Copyright (c) 2009 The openGion Project. 003 * 004 * Licensed under the Apache License, Version 2.0 (the "License"); 005 * you may not use this file except in compliance with the License. 006 * You may obtain a copy of the License at 007 * 008 * http://www.apache.org/licenses/LICENSE-2.0 009 * 010 * Unless required by applicable law or agreed to in writing, software 011 * distributed under the License is distributed on an "AS IS" BASIS, 012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, 013 * either express or implied. See the License for the specific language 014 * governing permissions and limitations under the License. 015 */ 016 017package org.opengion.fukurou.queue; 018 019/** 020 * キュー送信クラス用インタフェース 021 * キュー送信クラス実装用のインタフェースです。 022 * 023 * @og.rev 5.10.14.0 (2019/08/01) 新規作成 024 * 025 */ 026public interface QueueSend { 027 /** 028 * 接続処理 029 * メッセージキューサーバに接続します。 030 * 031 * @param jmsServer jmsServer接続先 032 */ 033// public void connect(final String jmrServer); 034 035 /** 036 * 接続処理 037 * キー情報を利用してメッセージキューサーバに接続します。 038 * SQSサーバの利用で、アクセスキーを利用した接続を行う場合用です。 039 * MQサーバの場合は、キーは利用されず、connect(final String jmsServer)と同様の動作になります。 040 * 041 * @og.rev 5.10.15.0 (2019/08/30) 引数追加 042 * 043 * @param jmsServer JMSサーバ接続先 044 * @param sqsAccessKey アクセスキー 045 * @param sqsSecretKey シークレットキー 046 */ 047 public void connect(final String jmsServer, final String sqsAccessKey, final String sqsSecretKey); 048 049 /** 050 * メッセージ送信処理 051 * キューサーバにメッセージを送信します。 052 * 053 * @param queueInfo 送信キュー情報 054 */ 055 public void sendMessage(QueueInfo queueInfo); 056 057 /** 058 * クローズ処理 059 * キューサーバの接続をクローズします。 060 * 061 */ 062 public void close(); 063 064 /** 065 * バッチ処理判定 066 * バッチ処理判定を設定します。 067 * 068 * @param batchFlg バッチ処理判定 069 */ 070 public void setBatchFlg(final Boolean batchFlg); 071}