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}