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}