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}