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}