1
1
/// <reference path="aws-sdk.d.ts" />
2
2
3
- import awsSdk = require( 'aws-sdk' ) ;
3
+ import AWS = require( 'aws-sdk' ) ;
4
4
5
5
var str : string ;
6
6
7
- var creds : awsSdk . Credentials ;
7
+ var creds : AWS . Credentials ;
8
8
9
- creds = new awsSdk . Credentials ( str , str ) ;
10
- creds = new awsSdk . Credentials ( str , str , str ) ;
9
+ creds = new AWS . Credentials ( str , str ) ;
10
+ creds = new AWS . Credentials ( str , str , str ) ;
11
11
str = creds . accessKeyId ;
12
12
13
- // more
13
+
14
+ /*
15
+ * SQS
16
+ */
17
+ var sqs :AWS . SQS
18
+
19
+ //Default constructor
20
+ sqs = new AWS . SQS ( ) ;
21
+
22
+ //Locking the API Version
23
+ sqs = new AWS . SQS ( { apiVersion : '2012-11-05' } ) ;
24
+
25
+ // Locking the API Version Globally
26
+ AWS . config . apiVersions = {
27
+ sqs : '2012-11-05' ,
28
+ // other service API versions
29
+ } ;
30
+
31
+ sqs . addPermission ( {
32
+ AWSAccountIds : [ /* required */
33
+ 'STRING_VALUE' ,
34
+ /* more items */
35
+ ] ,
36
+ Actions : [ /* required */
37
+ 'STRING_VALUE' ,
38
+ /* more items */
39
+ ] ,
40
+ Label : 'STRING_VALUE' , /* required */
41
+ QueueUrl : 'STRING_VALUE' /* required */
42
+ } ,
43
+ function ( err , data ) {
44
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
45
+ else console . log ( data ) ; // successful response
46
+ } ) ;
47
+
48
+ sqs . changeMessageVisibility ( {
49
+ QueueUrl : 'STRING_VALUE' , /* required */
50
+ ReceiptHandle : 'STRING_VALUE' , /* required */
51
+ VisibilityTimeout : 0 /* required */
52
+ } ,
53
+ function ( err , data ) {
54
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
55
+ else console . log ( data ) ; // successful response
56
+ } ) ;
57
+
58
+ sqs . changeMessageVisibilityBatch ( {
59
+ Entries : [ /* required */
60
+ {
61
+ Id : 'STRING_VALUE' , /* required */
62
+ ReceiptHandle : 'STRING_VALUE' , /* required */
63
+ VisibilityTimeout : 0
64
+ } ,
65
+ /* more items */
66
+ ] ,
67
+ QueueUrl : 'STRING_VALUE' /* required */
68
+ } ,
69
+ function ( err , data ) {
70
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
71
+ else console . log ( data ) ; // successful response
72
+ } ) ;
73
+
74
+ sqs . createQueue ( {
75
+ QueueName : 'STRING_VALUE' , /* required */
76
+ Attributes : {
77
+ someKey : 'STRING_VALUE' ,
78
+ /* anotherKey: ... */
79
+ }
80
+ } ,
81
+ function ( err , data ) {
82
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
83
+ else console . log ( data ) ; // successful response
84
+ } ) ;
85
+
86
+ sqs . deleteMessage ( {
87
+ QueueUrl : 'STRING_VALUE' , /* required */
88
+ ReceiptHandle : 'STRING_VALUE' /* required */
89
+ } ,
90
+ function ( err , data ) {
91
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
92
+ else console . log ( data ) ; // successful response
93
+ } ) ;
94
+
95
+ sqs . deleteMessageBatch ( {
96
+ Entries : [ /* required */
97
+ {
98
+ Id : 'STRING_VALUE' , /* required */
99
+ ReceiptHandle : 'STRING_VALUE' /* required */
100
+ } ,
101
+ /* more items */
102
+ ] ,
103
+ QueueUrl : 'STRING_VALUE' /* required */
104
+ } ,
105
+ function ( err , data ) {
106
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
107
+ else console . log ( data ) ; // successful response
108
+ } ) ;
109
+
110
+ sqs . deleteQueue ( {
111
+ QueueUrl : 'STRING_VALUE' /* required */
112
+ } ,
113
+ function ( err , data ) {
114
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
115
+ else console . log ( data ) ; // successful response
116
+ } ) ;
117
+
118
+ sqs . getQueueAttributes ( {
119
+ QueueUrl : 'STRING_VALUE' , /* required */
120
+ AttributeNames : [
121
+ 'Policy | VisibilityTimeout | MaximumMessageSize | MessageRetentionPeriod | ApproximateNumberOfMessages | ApproximateNumberOfMessagesNotVisible | CreatedTimestamp | LastModifiedTimestamp | QueueArn | ApproximateNumberOfMessagesDelayed | DelaySeconds | ReceiveMessageWaitTimeSeconds | RedrivePolicy' ,
122
+ /* more items */
123
+ ]
124
+ } ,
125
+ function ( err , data ) {
126
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
127
+ else console . log ( data ) ; // successful response
128
+ } ) ;
129
+
130
+ sqs . getQueueUrl ( {
131
+ QueueName : 'STRING_VALUE' , /* required */
132
+ QueueOwnerAWSAccountId : 'STRING_VALUE'
133
+ } ,
134
+ function ( err , data ) {
135
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
136
+ else console . log ( data ) ; // successful response
137
+ } ) ;
138
+
139
+ sqs . listDeadLetterSourceQueues ( {
140
+ QueueUrl : 'STRING_VALUE' /* required */
141
+ } , function ( err , data ) {
142
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
143
+ else console . log ( data ) ; // successful response
144
+ } ) ;
145
+
146
+ sqs . listQueues ( {
147
+ QueueNamePrefix : 'STRING_VALUE'
148
+ } ,
149
+ function ( err , data ) {
150
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
151
+ else console . log ( data ) ; // successful response
152
+ } ) ;
153
+
154
+ sqs . purgeQueue ( {
155
+ QueueUrl : 'STRING_VALUE' /* required */
156
+ } , function ( err , data ) {
157
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
158
+ else console . log ( data ) ; // successful response
159
+ } ) ;
160
+
161
+ sqs . receiveMessage ( {
162
+ QueueUrl : 'STRING_VALUE' , /* required */
163
+ AttributeNames : [
164
+ 'Policy | VisibilityTimeout | MaximumMessageSize | MessageRetentionPeriod | ApproximateNumberOfMessages | ApproximateNumberOfMessagesNotVisible | CreatedTimestamp | LastModifiedTimestamp | QueueArn | ApproximateNumberOfMessagesDelayed | DelaySeconds | ReceiveMessageWaitTimeSeconds | RedrivePolicy' ,
165
+ /* more items */
166
+ ] ,
167
+ MaxNumberOfMessages : 0 ,
168
+ MessageAttributeNames : [
169
+ 'STRING_VALUE' ,
170
+ /* more items */
171
+ ] ,
172
+ VisibilityTimeout : 0 ,
173
+ WaitTimeSeconds : 0
174
+ } , function ( err , data ) {
175
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
176
+ else console . log ( data ) ; // successful response
177
+ } ) ;
178
+
179
+ sqs . removePermission ( {
180
+ Label : 'STRING_VALUE' , /* required */
181
+ QueueUrl : 'STRING_VALUE' /* required */
182
+ } , function ( err , data ) {
183
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
184
+ else console . log ( data ) ; // successful response
185
+ } ) ;
186
+
187
+ sqs . sendMessage ( {
188
+ MessageBody : 'STRING_VALUE' , /* required */
189
+ QueueUrl : 'STRING_VALUE' , /* required */
190
+ DelaySeconds : 0 ,
191
+ MessageAttributes : {
192
+ someKey : {
193
+ DataType : 'STRING_VALUE' , /* required */
194
+ BinaryListValues : [
195
+ new Buffer ( '...' ) || 'STRING_VALUE' ,
196
+ /* more items */
197
+ ] ,
198
+ BinaryValue : new Buffer ( '...' ) || 'STRING_VALUE' ,
199
+ StringListValues : [
200
+ 'STRING_VALUE' ,
201
+ /* more items */
202
+ ] ,
203
+ StringValue : 'STRING_VALUE'
204
+ } ,
205
+ /* anotherKey: ... */
206
+ }
207
+ } ,
208
+ function ( err , data ) {
209
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
210
+ else console . log ( data ) ; // successful response
211
+ } ) ;
212
+
213
+ sqs . sendMessageBatch ( {
214
+ Entries : [ /* required */
215
+ {
216
+ Id : 'STRING_VALUE' , /* required */
217
+ MessageBody : 'STRING_VALUE' , /* required */
218
+ DelaySeconds : 0 ,
219
+ MessageAttributes : {
220
+ someKey : {
221
+ DataType : 'STRING_VALUE' , /* required */
222
+ BinaryListValues : [
223
+ new Buffer ( '...' ) ,
224
+ /* more items */
225
+ ] ,
226
+ BinaryValue : new Buffer ( '...' ) ,
227
+ StringListValues : [
228
+ 'STRING_VALUE' ,
229
+ /* more items */
230
+ ] ,
231
+ StringValue : 'STRING_VALUE'
232
+ } ,
233
+ /* anotherKey: ... */
234
+ }
235
+ } ,
236
+ /* more items */
237
+ ] ,
238
+ QueueUrl : 'STRING_VALUE' /* required */
239
+ } ,
240
+ function ( err , data ) {
241
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
242
+ else console . log ( data ) ; // successful response
243
+ } ) ;
244
+
245
+ sqs . setQueueAttributes ( {
246
+ Attributes : { /* required */
247
+ someKey : 'STRING_VALUE' ,
248
+ /* anotherKey: ... */
249
+ } ,
250
+ QueueUrl : 'STRING_VALUE' /* required */
251
+ } , function ( err , data ) {
252
+ if ( err ) console . log ( err , err . stack ) ; // an error occurred
253
+ else console . log ( data ) ; // successful response
254
+ } ) ;
255
+
256
+
0 commit comments