forked from aws/aws-sdk-java
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathChangeMessageVisibilityRequest.java
More file actions
248 lines (216 loc) · 9.58 KB
/
ChangeMessageVisibilityRequest.java
File metadata and controls
248 lines (216 loc) · 9.58 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
/*
* Copyright 2010-2013 Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file is distributed
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
package com.amazonaws.services.sqs.model;
import java.io.Serializable;
import com.amazonaws.AmazonWebServiceRequest;
/**
* Container for the parameters to the {@link com.amazonaws.services.sqs.AmazonSQS#changeMessageVisibility(ChangeMessageVisibilityRequest) ChangeMessageVisibility operation}.
* <p>
* The <code>ChangeMessageVisibility</code> action changes the visibility timeout of a specified message in a queue to a new value. The maximum allowed
* timeout value you can set the value to is 12 hours. This means you can't extend the timeout of a message in an existing queue to more than a total
* visibility timeout of 12 hours. (For more information visibility timeout, see <a
* href="http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/AboutVT.html"> Visibility Timeout </a> in the Amazon SQS Developer
* Guide.)
* </p>
* <p>
* For example, let's say you have a message and its default message visibility timeout is 30 minutes. You could call <code>ChangeMessageVisiblity</code>
* with a value of two hours and the effective timeout would be two hours and 30 minutes. When that time comes near you could again extend the time out
* by calling ChangeMessageVisiblity, but this time the maximum allowed timeout would be 9 hours and 30 minutes.
* </p>
* <p>
* <b>IMPORTANT:</b>If you attempt to set the VisibilityTimeout to an amount more than the maximum time left, Amazon SQS returns an error. It will not
* automatically recalculate and increase the timeout to the maximum time remaining.
* </p>
* <p>
* <b>IMPORTANT:</b>Unlike with a queue, when you change the visibility timeout for a specific message, that timeout value is applied immediately but is
* not saved in memory for that message. If you don't delete a message after it is received, the visibility timeout for the message the next time it is
* received reverts to the original timeout value, not the value you set with the ChangeMessageVisibility action.
* </p>
*
* @see com.amazonaws.services.sqs.AmazonSQS#changeMessageVisibility(ChangeMessageVisibilityRequest)
*/
public class ChangeMessageVisibilityRequest extends AmazonWebServiceRequest implements Serializable {
/**
* The URL of the SQS queue to take action on.
*/
private String queueUrl;
/**
* The receipt handle associated with the message whose visibility
* timeout should be changed.
*/
private String receiptHandle;
/**
* The new value (in seconds) for the message's visibility timeout.
*/
private Integer visibilityTimeout;
/**
* Default constructor for a new ChangeMessageVisibilityRequest object. Callers should use the
* setter or fluent setter (with...) methods to initialize this object after creating it.
*/
public ChangeMessageVisibilityRequest() {}
/**
* Constructs a new ChangeMessageVisibilityRequest object.
* Callers should use the setter or fluent setter (with...) methods to
* initialize any additional object members.
*
* @param queueUrl The URL of the SQS queue to take action on.
* @param receiptHandle The receipt handle associated with the message
* whose visibility timeout should be changed.
* @param visibilityTimeout The new value (in seconds) for the message's
* visibility timeout.
*/
public ChangeMessageVisibilityRequest(String queueUrl, String receiptHandle, Integer visibilityTimeout) {
setQueueUrl(queueUrl);
setReceiptHandle(receiptHandle);
setVisibilityTimeout(visibilityTimeout);
}
/**
* The URL of the SQS queue to take action on.
*
* @return The URL of the SQS queue to take action on.
*/
public String getQueueUrl() {
return queueUrl;
}
/**
* The URL of the SQS queue to take action on.
*
* @param queueUrl The URL of the SQS queue to take action on.
*/
public void setQueueUrl(String queueUrl) {
this.queueUrl = queueUrl;
}
/**
* The URL of the SQS queue to take action on.
* <p>
* Returns a reference to this object so that method calls can be chained together.
*
* @param queueUrl The URL of the SQS queue to take action on.
*
* @return A reference to this updated object so that method calls can be chained
* together.
*/
public ChangeMessageVisibilityRequest withQueueUrl(String queueUrl) {
this.queueUrl = queueUrl;
return this;
}
/**
* The receipt handle associated with the message whose visibility
* timeout should be changed.
*
* @return The receipt handle associated with the message whose visibility
* timeout should be changed.
*/
public String getReceiptHandle() {
return receiptHandle;
}
/**
* The receipt handle associated with the message whose visibility
* timeout should be changed.
*
* @param receiptHandle The receipt handle associated with the message whose visibility
* timeout should be changed.
*/
public void setReceiptHandle(String receiptHandle) {
this.receiptHandle = receiptHandle;
}
/**
* The receipt handle associated with the message whose visibility
* timeout should be changed.
* <p>
* Returns a reference to this object so that method calls can be chained together.
*
* @param receiptHandle The receipt handle associated with the message whose visibility
* timeout should be changed.
*
* @return A reference to this updated object so that method calls can be chained
* together.
*/
public ChangeMessageVisibilityRequest withReceiptHandle(String receiptHandle) {
this.receiptHandle = receiptHandle;
return this;
}
/**
* The new value (in seconds) for the message's visibility timeout.
*
* @return The new value (in seconds) for the message's visibility timeout.
*/
public Integer getVisibilityTimeout() {
return visibilityTimeout;
}
/**
* The new value (in seconds) for the message's visibility timeout.
*
* @param visibilityTimeout The new value (in seconds) for the message's visibility timeout.
*/
public void setVisibilityTimeout(Integer visibilityTimeout) {
this.visibilityTimeout = visibilityTimeout;
}
/**
* The new value (in seconds) for the message's visibility timeout.
* <p>
* Returns a reference to this object so that method calls can be chained together.
*
* @param visibilityTimeout The new value (in seconds) for the message's visibility timeout.
*
* @return A reference to this updated object so that method calls can be chained
* together.
*/
public ChangeMessageVisibilityRequest withVisibilityTimeout(Integer visibilityTimeout) {
this.visibilityTimeout = visibilityTimeout;
return this;
}
/**
* Returns a string representation of this object; useful for testing and
* debugging.
*
* @return A string representation of this object.
*
* @see java.lang.Object#toString()
*/
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("{");
if (getQueueUrl() != null) sb.append("QueueUrl: " + getQueueUrl() + ",");
if (getReceiptHandle() != null) sb.append("ReceiptHandle: " + getReceiptHandle() + ",");
if (getVisibilityTimeout() != null) sb.append("VisibilityTimeout: " + getVisibilityTimeout() );
sb.append("}");
return sb.toString();
}
@Override
public int hashCode() {
final int prime = 31;
int hashCode = 1;
hashCode = prime * hashCode + ((getQueueUrl() == null) ? 0 : getQueueUrl().hashCode());
hashCode = prime * hashCode + ((getReceiptHandle() == null) ? 0 : getReceiptHandle().hashCode());
hashCode = prime * hashCode + ((getVisibilityTimeout() == null) ? 0 : getVisibilityTimeout().hashCode());
return hashCode;
}
@Override
public boolean equals(Object obj) {
if (this == obj) return true;
if (obj == null) return false;
if (obj instanceof ChangeMessageVisibilityRequest == false) return false;
ChangeMessageVisibilityRequest other = (ChangeMessageVisibilityRequest)obj;
if (other.getQueueUrl() == null ^ this.getQueueUrl() == null) return false;
if (other.getQueueUrl() != null && other.getQueueUrl().equals(this.getQueueUrl()) == false) return false;
if (other.getReceiptHandle() == null ^ this.getReceiptHandle() == null) return false;
if (other.getReceiptHandle() != null && other.getReceiptHandle().equals(this.getReceiptHandle()) == false) return false;
if (other.getVisibilityTimeout() == null ^ this.getVisibilityTimeout() == null) return false;
if (other.getVisibilityTimeout() != null && other.getVisibilityTimeout().equals(this.getVisibilityTimeout()) == false) return false;
return true;
}
}