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