    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 */
    016package org.opengion.fukurou.queue;
    017
    018import javax.jms.QueueSession;
    019
    020/**
    021 * キュー情報格納クラス キュー情報を格納するクラスです。
    022 *
    023 * @og.rev 5.10.14.0 (2019/08/01) 新規作成
    024 *
    025 */
    026public class QueueInfo {
    027        // jmsServer
    028        private String jmsServer;
    029        // メッセージ
    030        private String message;
    031        // SQSFIFOグループID
    032        private String sqsFifoGroupId;
    033        // SQSFIFO重複排除ID
    034        private String sqsFifoDedupliId;
    035        // MQキュー名
    036        private String mqQueueName;
    037        // MQトランザクション処理判別
    038        private Boolean mqTransacted;
    039        // MQ確認応答モード
    040        private int mqAcknowledgeMode;;
    041
    042        /**
    043         * コントラクタ パラメータを初期化します。
    044         */
    045        public QueueInfo() {
    046                jmsServer                       = null;
    047                message                         = null;
    048                sqsFifoGroupId          = null;
    049                sqsFifoDedupliId        = null;
    050                mqQueueName                     = null;
    051                mqTransacted            = false;
    052                mqAcknowledgeMode       = QueueSession.AUTO_ACKNOWLEDGE;
    053        }
    054
    055        /** Getter：Setter */
    056        /**
    057         * メッセージを取得します。
    058         *
    059         * @return メッセージ
    060         */
    061        public String getMessage() {
    062                return message;
    063        }
    064
    065        /**
    066         * メッセージを設定します。
    067         *
    068         * @param mess メッセージ
    069         */
    070        public void setMessage(final String mess) {
    071                message = mess;
    072        }
    073
    074        /**
    075         * Jmsサーバを取得します。
    076         *
    077         * @return JMSサーバ
    078         */
    079        public String getJmsServer() {
    080                return jmsServer;
    081        }
    082
    083        /**
    084         * Jmsサーバーを設定します。
    085         *
    086         * @param server Jmsサーバ(コンテキストに定義された名称)
    087         */
    088        public void setJmsServer(final String server) {
    089                jmsServer = server;
    090        }
    091
    092        /**
    093         * SQSFIFO用のグループIDを取得します。
    094         *
    095         * @return SQSFIFO用グループID
    096         */
    097        public String getSqsFifoGroupId() {
    098                return sqsFifoGroupId;
    099        }
    100
    101        /**
    102         * SQSFIFO用のグループIDを設定します。
    103         *
    104         * @param id SQSFIFO用グループID
    105         */
    106        public void setSqsFifoGroupId(final String id) {
    107                sqsFifoGroupId = id;
    108        }
    109
    110        /**
    111         * SQSFIFO用の重複排除IDを取得します。
    112         *
    113         * @return SQSFIFO用の重複排除ID
    114         */
    115        public String getSqsFifoDedupliId() {
    116                return sqsFifoDedupliId;
    117        }
    118
    119        /**
    120         * SQSFIFO用の重複排除IDを設定します。
    121         *
    122         * @param dedupliId SQSFIFO用の重複排除ID
    123         */
    124        public void setSqsFifoDedupliId(final String dedupliId) {
    125                sqsFifoDedupliId = dedupliId;
    126        }
    127
    128        /**
    129         * MQ用のトランザクション処理指定フラグを取得します。
    130         *
    131         * @return MQ用のトランザクション処理指定フラグ
    132         */
    133        public Boolean isMqTransacted() {
    134                return mqTransacted;
    135        }
    136
    137        /**
    138         * MQ用のトランザクション処理指定フラグを設定します。
    139         *
    140         * @param mqFlgTransacted MQ用のトランザクションン処理指定フラグ
    141         */
    142        public void setMqTransacted(final Boolean mqFlgTransacted) {
    143                mqTransacted = mqFlgTransacted;
    144        }
    145
    146        /**
    147         * MQ用の確認応答モードを取得します。
    148         *
    149         * @return MQ用の確認応答モード
    150         */
    151        public int getMqAcknowledgeMode() {
    152                return mqAcknowledgeMode;
    153        }
    154
    155        /**
    156         * MQ用の確認応答モードを設定します。
    157         *
    158         * @param ackMode MQ用の確認応答モード
    159         */
    160        public void setMqAcknowledgeMode(final int ackMode) {
    161                mqAcknowledgeMode = ackMode;
    162        }
    163
    164        /**
    165         * MQ用のキュー名を取得します。
    166         *
    167         * @return MQ用のキュー名
    168         */
    169        public String getMqQueueName() {
    170                return mqQueueName;
    171        }
    172
    173        /**
    174         * MQ用のキュー名を設定します。
    175         *
    176         * @param qName MQ用のキュー名
    177         */
    178        public void setMqQueueName(final String qName) {
    179                mqQueueName = qName;
    180        }
    181}