Subversion Repositories SmartDukaan

Rev

Rev 3431 | Rev 3530 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
3131 rajveer 1
#
3431 rajveer 2
# Autogenerated by Thrift Compiler (0.7.0)
3131 rajveer 3
#
4
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
5
#
6
 
7
from thrift.Thrift import *
3376 rajveer 8
import shop2020.thriftpy.generic.GenericService
3131 rajveer 9
from ttypes import *
10
from thrift.Thrift import TProcessor
11
from thrift.transport import TTransport
3431 rajveer 12
from thrift.protocol import TBinaryProtocol, TProtocol
3131 rajveer 13
try:
14
  from thrift.protocol import fastbinary
15
except:
16
  fastbinary = None
17
 
18
 
3376 rajveer 19
class Iface(shop2020.thriftpy.generic.GenericService.Iface):
3431 rajveer 20
  def getTickets(self, searchFilter):
3131 rajveer 21
    """
22
    Parameters:
3431 rajveer 23
     - searchFilter
3131 rajveer 24
    """
25
    pass
26
 
3376 rajveer 27
  def getUnassignedTickets(self, ):
3131 rajveer 28
    pass
29
 
3376 rajveer 30
  def updateTicket(self, ticket, activity):
3131 rajveer 31
    """
32
    Parameters:
33
     - ticket
3376 rajveer 34
     - activity
3131 rajveer 35
    """
36
    pass
37
 
3376 rajveer 38
  def insertTicket(self, ticket, activity):
3131 rajveer 39
    """
40
    Parameters:
41
     - ticket
3376 rajveer 42
     - activity
3131 rajveer 43
    """
44
    pass
45
 
3431 rajveer 46
  def getActivities(self, searchFilter):
3131 rajveer 47
    """
48
    Parameters:
3431 rajveer 49
     - searchFilter
3131 rajveer 50
    """
51
    pass
52
 
53
  def insertActivity(self, activity):
54
    """
55
    Parameters:
56
     - activity
57
    """
58
    pass
59
 
3431 rajveer 60
  def markAsRead(self, activityId, agentId):
3131 rajveer 61
    """
62
    Parameters:
3431 rajveer 63
     - activityId
3131 rajveer 64
     - agentId
65
    """
66
    pass
67
 
3431 rajveer 68
  def getAgents(self, searchFilter):
3131 rajveer 69
    """
70
    Parameters:
3431 rajveer 71
     - searchFilter
3131 rajveer 72
    """
73
    pass
74
 
75
  def updatePasswordForAgent(self, agentEmailId, password):
76
    """
77
    Parameters:
78
     - agentEmailId
79
     - password
80
    """
81
    pass
82
 
83
  def getRoleNamesForAgent(self, agentEmailId):
84
    """
85
    Parameters:
86
     - agentEmailId
87
    """
88
    pass
89
 
90
  def getPermissionsForRoleName(self, roleName):
91
    """
92
    Parameters:
93
     - roleName
94
    """
95
    pass
96
 
3376 rajveer 97
  def getLastEmailProcessedTimestamp(self, ):
98
    pass
3131 rajveer 99
 
3376 rajveer 100
  def updateLastEmailProcessedTimestamp(self, timestamp):
101
    """
102
    Parameters:
103
     - timestamp
104
    """
105
    pass
106
 
3499 mandeep.dh 107
  def processCODTxn(self, transactionId):
108
    """
109
    Parameters:
110
     - transactionId
111
    """
112
    pass
3376 rajveer 113
 
3499 mandeep.dh 114
 
3376 rajveer 115
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
3131 rajveer 116
  def __init__(self, iprot, oprot=None):
3376 rajveer 117
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
3131 rajveer 118
 
3431 rajveer 119
  def getTickets(self, searchFilter):
3131 rajveer 120
    """
121
    Parameters:
3431 rajveer 122
     - searchFilter
3131 rajveer 123
    """
3431 rajveer 124
    self.send_getTickets(searchFilter)
3131 rajveer 125
    return self.recv_getTickets()
126
 
3431 rajveer 127
  def send_getTickets(self, searchFilter):
3131 rajveer 128
    self._oprot.writeMessageBegin('getTickets', TMessageType.CALL, self._seqid)
129
    args = getTickets_args()
3431 rajveer 130
    args.searchFilter = searchFilter
3131 rajveer 131
    args.write(self._oprot)
132
    self._oprot.writeMessageEnd()
133
    self._oprot.trans.flush()
134
 
135
  def recv_getTickets(self, ):
136
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
137
    if mtype == TMessageType.EXCEPTION:
138
      x = TApplicationException()
139
      x.read(self._iprot)
140
      self._iprot.readMessageEnd()
141
      raise x
142
    result = getTickets_result()
143
    result.read(self._iprot)
144
    self._iprot.readMessageEnd()
3431 rajveer 145
    if result.success is not None:
3131 rajveer 146
      return result.success
147
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getTickets failed: unknown result");
148
 
3376 rajveer 149
  def getUnassignedTickets(self, ):
150
    self.send_getUnassignedTickets()
151
    return self.recv_getUnassignedTickets()
3131 rajveer 152
 
3376 rajveer 153
  def send_getUnassignedTickets(self, ):
154
    self._oprot.writeMessageBegin('getUnassignedTickets', TMessageType.CALL, self._seqid)
155
    args = getUnassignedTickets_args()
3131 rajveer 156
    args.write(self._oprot)
157
    self._oprot.writeMessageEnd()
158
    self._oprot.trans.flush()
159
 
3376 rajveer 160
  def recv_getUnassignedTickets(self, ):
3131 rajveer 161
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
162
    if mtype == TMessageType.EXCEPTION:
163
      x = TApplicationException()
164
      x.read(self._iprot)
165
      self._iprot.readMessageEnd()
166
      raise x
3376 rajveer 167
    result = getUnassignedTickets_result()
3131 rajveer 168
    result.read(self._iprot)
169
    self._iprot.readMessageEnd()
3431 rajveer 170
    if result.success is not None:
3131 rajveer 171
      return result.success
3376 rajveer 172
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnassignedTickets failed: unknown result");
3131 rajveer 173
 
3376 rajveer 174
  def updateTicket(self, ticket, activity):
3131 rajveer 175
    """
176
    Parameters:
177
     - ticket
3376 rajveer 178
     - activity
3131 rajveer 179
    """
3376 rajveer 180
    self.send_updateTicket(ticket, activity)
3131 rajveer 181
    self.recv_updateTicket()
182
 
3376 rajveer 183
  def send_updateTicket(self, ticket, activity):
3131 rajveer 184
    self._oprot.writeMessageBegin('updateTicket', TMessageType.CALL, self._seqid)
185
    args = updateTicket_args()
186
    args.ticket = ticket
3376 rajveer 187
    args.activity = activity
3131 rajveer 188
    args.write(self._oprot)
189
    self._oprot.writeMessageEnd()
190
    self._oprot.trans.flush()
191
 
192
  def recv_updateTicket(self, ):
193
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
194
    if mtype == TMessageType.EXCEPTION:
195
      x = TApplicationException()
196
      x.read(self._iprot)
197
      self._iprot.readMessageEnd()
198
      raise x
199
    result = updateTicket_result()
200
    result.read(self._iprot)
201
    self._iprot.readMessageEnd()
202
    return
203
 
3376 rajveer 204
  def insertTicket(self, ticket, activity):
3131 rajveer 205
    """
206
    Parameters:
207
     - ticket
3376 rajveer 208
     - activity
3131 rajveer 209
    """
3376 rajveer 210
    self.send_insertTicket(ticket, activity)
3131 rajveer 211
    return self.recv_insertTicket()
212
 
3376 rajveer 213
  def send_insertTicket(self, ticket, activity):
3131 rajveer 214
    self._oprot.writeMessageBegin('insertTicket', TMessageType.CALL, self._seqid)
215
    args = insertTicket_args()
216
    args.ticket = ticket
3376 rajveer 217
    args.activity = activity
3131 rajveer 218
    args.write(self._oprot)
219
    self._oprot.writeMessageEnd()
220
    self._oprot.trans.flush()
221
 
222
  def recv_insertTicket(self, ):
223
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
224
    if mtype == TMessageType.EXCEPTION:
225
      x = TApplicationException()
226
      x.read(self._iprot)
227
      self._iprot.readMessageEnd()
228
      raise x
229
    result = insertTicket_result()
230
    result.read(self._iprot)
231
    self._iprot.readMessageEnd()
3431 rajveer 232
    if result.success is not None:
3131 rajveer 233
      return result.success
234
    raise TApplicationException(TApplicationException.MISSING_RESULT, "insertTicket failed: unknown result");
235
 
3431 rajveer 236
  def getActivities(self, searchFilter):
3131 rajveer 237
    """
238
    Parameters:
3431 rajveer 239
     - searchFilter
3131 rajveer 240
    """
3431 rajveer 241
    self.send_getActivities(searchFilter)
3131 rajveer 242
    return self.recv_getActivities()
243
 
3431 rajveer 244
  def send_getActivities(self, searchFilter):
3131 rajveer 245
    self._oprot.writeMessageBegin('getActivities', TMessageType.CALL, self._seqid)
246
    args = getActivities_args()
3431 rajveer 247
    args.searchFilter = searchFilter
3131 rajveer 248
    args.write(self._oprot)
249
    self._oprot.writeMessageEnd()
250
    self._oprot.trans.flush()
251
 
252
  def recv_getActivities(self, ):
253
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
254
    if mtype == TMessageType.EXCEPTION:
255
      x = TApplicationException()
256
      x.read(self._iprot)
257
      self._iprot.readMessageEnd()
258
      raise x
259
    result = getActivities_result()
260
    result.read(self._iprot)
261
    self._iprot.readMessageEnd()
3431 rajveer 262
    if result.success is not None:
3131 rajveer 263
      return result.success
264
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getActivities failed: unknown result");
265
 
266
  def insertActivity(self, activity):
267
    """
268
    Parameters:
269
     - activity
270
    """
271
    self.send_insertActivity(activity)
3431 rajveer 272
    return self.recv_insertActivity()
3131 rajveer 273
 
274
  def send_insertActivity(self, activity):
275
    self._oprot.writeMessageBegin('insertActivity', TMessageType.CALL, self._seqid)
276
    args = insertActivity_args()
277
    args.activity = activity
278
    args.write(self._oprot)
279
    self._oprot.writeMessageEnd()
280
    self._oprot.trans.flush()
281
 
282
  def recv_insertActivity(self, ):
283
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
284
    if mtype == TMessageType.EXCEPTION:
285
      x = TApplicationException()
286
      x.read(self._iprot)
287
      self._iprot.readMessageEnd()
288
      raise x
289
    result = insertActivity_result()
290
    result.read(self._iprot)
291
    self._iprot.readMessageEnd()
3431 rajveer 292
    if result.success is not None:
3131 rajveer 293
      return result.success
3431 rajveer 294
    raise TApplicationException(TApplicationException.MISSING_RESULT, "insertActivity failed: unknown result");
3131 rajveer 295
 
3431 rajveer 296
  def markAsRead(self, activityId, agentId):
3131 rajveer 297
    """
298
    Parameters:
3431 rajveer 299
     - activityId
3131 rajveer 300
     - agentId
301
    """
3431 rajveer 302
    self.send_markAsRead(activityId, agentId)
303
    self.recv_markAsRead()
3131 rajveer 304
 
3431 rajveer 305
  def send_markAsRead(self, activityId, agentId):
306
    self._oprot.writeMessageBegin('markAsRead', TMessageType.CALL, self._seqid)
307
    args = markAsRead_args()
308
    args.activityId = activityId
3131 rajveer 309
    args.agentId = agentId
310
    args.write(self._oprot)
311
    self._oprot.writeMessageEnd()
312
    self._oprot.trans.flush()
313
 
3431 rajveer 314
  def recv_markAsRead(self, ):
3131 rajveer 315
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
316
    if mtype == TMessageType.EXCEPTION:
317
      x = TApplicationException()
318
      x.read(self._iprot)
319
      self._iprot.readMessageEnd()
320
      raise x
3431 rajveer 321
    result = markAsRead_result()
3131 rajveer 322
    result.read(self._iprot)
323
    self._iprot.readMessageEnd()
3431 rajveer 324
    return
3131 rajveer 325
 
3431 rajveer 326
  def getAgents(self, searchFilter):
3131 rajveer 327
    """
328
    Parameters:
3431 rajveer 329
     - searchFilter
3131 rajveer 330
    """
3431 rajveer 331
    self.send_getAgents(searchFilter)
332
    return self.recv_getAgents()
3131 rajveer 333
 
3431 rajveer 334
  def send_getAgents(self, searchFilter):
335
    self._oprot.writeMessageBegin('getAgents', TMessageType.CALL, self._seqid)
336
    args = getAgents_args()
337
    args.searchFilter = searchFilter
3131 rajveer 338
    args.write(self._oprot)
339
    self._oprot.writeMessageEnd()
340
    self._oprot.trans.flush()
341
 
3431 rajveer 342
  def recv_getAgents(self, ):
3131 rajveer 343
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
344
    if mtype == TMessageType.EXCEPTION:
345
      x = TApplicationException()
346
      x.read(self._iprot)
347
      self._iprot.readMessageEnd()
348
      raise x
3431 rajveer 349
    result = getAgents_result()
3131 rajveer 350
    result.read(self._iprot)
351
    self._iprot.readMessageEnd()
3431 rajveer 352
    if result.success is not None:
3131 rajveer 353
      return result.success
3431 rajveer 354
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAgents failed: unknown result");
3131 rajveer 355
 
356
  def updatePasswordForAgent(self, agentEmailId, password):
357
    """
358
    Parameters:
359
     - agentEmailId
360
     - password
361
    """
362
    self.send_updatePasswordForAgent(agentEmailId, password)
363
    self.recv_updatePasswordForAgent()
364
 
365
  def send_updatePasswordForAgent(self, agentEmailId, password):
366
    self._oprot.writeMessageBegin('updatePasswordForAgent', TMessageType.CALL, self._seqid)
367
    args = updatePasswordForAgent_args()
368
    args.agentEmailId = agentEmailId
369
    args.password = password
370
    args.write(self._oprot)
371
    self._oprot.writeMessageEnd()
372
    self._oprot.trans.flush()
373
 
374
  def recv_updatePasswordForAgent(self, ):
375
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
376
    if mtype == TMessageType.EXCEPTION:
377
      x = TApplicationException()
378
      x.read(self._iprot)
379
      self._iprot.readMessageEnd()
380
      raise x
381
    result = updatePasswordForAgent_result()
382
    result.read(self._iprot)
383
    self._iprot.readMessageEnd()
384
    return
385
 
386
  def getRoleNamesForAgent(self, agentEmailId):
387
    """
388
    Parameters:
389
     - agentEmailId
390
    """
391
    self.send_getRoleNamesForAgent(agentEmailId)
392
    return self.recv_getRoleNamesForAgent()
393
 
394
  def send_getRoleNamesForAgent(self, agentEmailId):
395
    self._oprot.writeMessageBegin('getRoleNamesForAgent', TMessageType.CALL, self._seqid)
396
    args = getRoleNamesForAgent_args()
397
    args.agentEmailId = agentEmailId
398
    args.write(self._oprot)
399
    self._oprot.writeMessageEnd()
400
    self._oprot.trans.flush()
401
 
402
  def recv_getRoleNamesForAgent(self, ):
403
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
404
    if mtype == TMessageType.EXCEPTION:
405
      x = TApplicationException()
406
      x.read(self._iprot)
407
      self._iprot.readMessageEnd()
408
      raise x
409
    result = getRoleNamesForAgent_result()
410
    result.read(self._iprot)
411
    self._iprot.readMessageEnd()
3431 rajveer 412
    if result.success is not None:
3131 rajveer 413
      return result.success
414
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getRoleNamesForAgent failed: unknown result");
415
 
416
  def getPermissionsForRoleName(self, roleName):
417
    """
418
    Parameters:
419
     - roleName
420
    """
421
    self.send_getPermissionsForRoleName(roleName)
422
    return self.recv_getPermissionsForRoleName()
423
 
424
  def send_getPermissionsForRoleName(self, roleName):
425
    self._oprot.writeMessageBegin('getPermissionsForRoleName', TMessageType.CALL, self._seqid)
426
    args = getPermissionsForRoleName_args()
427
    args.roleName = roleName
428
    args.write(self._oprot)
429
    self._oprot.writeMessageEnd()
430
    self._oprot.trans.flush()
431
 
432
  def recv_getPermissionsForRoleName(self, ):
433
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
434
    if mtype == TMessageType.EXCEPTION:
435
      x = TApplicationException()
436
      x.read(self._iprot)
437
      self._iprot.readMessageEnd()
438
      raise x
439
    result = getPermissionsForRoleName_result()
440
    result.read(self._iprot)
441
    self._iprot.readMessageEnd()
3431 rajveer 442
    if result.success is not None:
3131 rajveer 443
      return result.success
444
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getPermissionsForRoleName failed: unknown result");
445
 
3376 rajveer 446
  def getLastEmailProcessedTimestamp(self, ):
447
    self.send_getLastEmailProcessedTimestamp()
448
    return self.recv_getLastEmailProcessedTimestamp()
3131 rajveer 449
 
3376 rajveer 450
  def send_getLastEmailProcessedTimestamp(self, ):
451
    self._oprot.writeMessageBegin('getLastEmailProcessedTimestamp', TMessageType.CALL, self._seqid)
452
    args = getLastEmailProcessedTimestamp_args()
453
    args.write(self._oprot)
454
    self._oprot.writeMessageEnd()
455
    self._oprot.trans.flush()
456
 
457
  def recv_getLastEmailProcessedTimestamp(self, ):
458
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
459
    if mtype == TMessageType.EXCEPTION:
460
      x = TApplicationException()
461
      x.read(self._iprot)
462
      self._iprot.readMessageEnd()
463
      raise x
464
    result = getLastEmailProcessedTimestamp_result()
465
    result.read(self._iprot)
466
    self._iprot.readMessageEnd()
3431 rajveer 467
    if result.success is not None:
3376 rajveer 468
      return result.success
469
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getLastEmailProcessedTimestamp failed: unknown result");
470
 
471
  def updateLastEmailProcessedTimestamp(self, timestamp):
472
    """
473
    Parameters:
474
     - timestamp
475
    """
476
    self.send_updateLastEmailProcessedTimestamp(timestamp)
477
    self.recv_updateLastEmailProcessedTimestamp()
478
 
479
  def send_updateLastEmailProcessedTimestamp(self, timestamp):
480
    self._oprot.writeMessageBegin('updateLastEmailProcessedTimestamp', TMessageType.CALL, self._seqid)
481
    args = updateLastEmailProcessedTimestamp_args()
482
    args.timestamp = timestamp
483
    args.write(self._oprot)
484
    self._oprot.writeMessageEnd()
485
    self._oprot.trans.flush()
486
 
487
  def recv_updateLastEmailProcessedTimestamp(self, ):
488
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
489
    if mtype == TMessageType.EXCEPTION:
490
      x = TApplicationException()
491
      x.read(self._iprot)
492
      self._iprot.readMessageEnd()
493
      raise x
494
    result = updateLastEmailProcessedTimestamp_result()
495
    result.read(self._iprot)
496
    self._iprot.readMessageEnd()
497
    return
498
 
3499 mandeep.dh 499
  def processCODTxn(self, transactionId):
500
    """
501
    Parameters:
502
     - transactionId
503
    """
504
    self.send_processCODTxn(transactionId)
505
    self.recv_processCODTxn()
3376 rajveer 506
 
3499 mandeep.dh 507
  def send_processCODTxn(self, transactionId):
508
    self._oprot.writeMessageBegin('processCODTxn', TMessageType.CALL, self._seqid)
509
    args = processCODTxn_args()
510
    args.transactionId = transactionId
511
    args.write(self._oprot)
512
    self._oprot.writeMessageEnd()
513
    self._oprot.trans.flush()
514
 
515
  def recv_processCODTxn(self, ):
516
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
517
    if mtype == TMessageType.EXCEPTION:
518
      x = TApplicationException()
519
      x.read(self._iprot)
520
      self._iprot.readMessageEnd()
521
      raise x
522
    result = processCODTxn_result()
523
    result.read(self._iprot)
524
    self._iprot.readMessageEnd()
525
    return
526
 
527
 
3376 rajveer 528
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
3131 rajveer 529
  def __init__(self, handler):
3376 rajveer 530
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
3131 rajveer 531
    self._processMap["getTickets"] = Processor.process_getTickets
3376 rajveer 532
    self._processMap["getUnassignedTickets"] = Processor.process_getUnassignedTickets
3131 rajveer 533
    self._processMap["updateTicket"] = Processor.process_updateTicket
534
    self._processMap["insertTicket"] = Processor.process_insertTicket
535
    self._processMap["getActivities"] = Processor.process_getActivities
536
    self._processMap["insertActivity"] = Processor.process_insertActivity
3431 rajveer 537
    self._processMap["markAsRead"] = Processor.process_markAsRead
538
    self._processMap["getAgents"] = Processor.process_getAgents
3131 rajveer 539
    self._processMap["updatePasswordForAgent"] = Processor.process_updatePasswordForAgent
540
    self._processMap["getRoleNamesForAgent"] = Processor.process_getRoleNamesForAgent
541
    self._processMap["getPermissionsForRoleName"] = Processor.process_getPermissionsForRoleName
3376 rajveer 542
    self._processMap["getLastEmailProcessedTimestamp"] = Processor.process_getLastEmailProcessedTimestamp
543
    self._processMap["updateLastEmailProcessedTimestamp"] = Processor.process_updateLastEmailProcessedTimestamp
3499 mandeep.dh 544
    self._processMap["processCODTxn"] = Processor.process_processCODTxn
3131 rajveer 545
 
546
  def process(self, iprot, oprot):
547
    (name, type, seqid) = iprot.readMessageBegin()
548
    if name not in self._processMap:
549
      iprot.skip(TType.STRUCT)
550
      iprot.readMessageEnd()
551
      x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
552
      oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
553
      x.write(oprot)
554
      oprot.writeMessageEnd()
555
      oprot.trans.flush()
556
      return
557
    else:
558
      self._processMap[name](self, seqid, iprot, oprot)
559
    return True
560
 
561
  def process_getTickets(self, seqid, iprot, oprot):
562
    args = getTickets_args()
563
    args.read(iprot)
564
    iprot.readMessageEnd()
565
    result = getTickets_result()
3431 rajveer 566
    result.success = self._handler.getTickets(args.searchFilter)
3131 rajveer 567
    oprot.writeMessageBegin("getTickets", TMessageType.REPLY, seqid)
568
    result.write(oprot)
569
    oprot.writeMessageEnd()
570
    oprot.trans.flush()
571
 
3376 rajveer 572
  def process_getUnassignedTickets(self, seqid, iprot, oprot):
573
    args = getUnassignedTickets_args()
3131 rajveer 574
    args.read(iprot)
575
    iprot.readMessageEnd()
3376 rajveer 576
    result = getUnassignedTickets_result()
577
    result.success = self._handler.getUnassignedTickets()
578
    oprot.writeMessageBegin("getUnassignedTickets", TMessageType.REPLY, seqid)
3131 rajveer 579
    result.write(oprot)
580
    oprot.writeMessageEnd()
581
    oprot.trans.flush()
582
 
583
  def process_updateTicket(self, seqid, iprot, oprot):
584
    args = updateTicket_args()
585
    args.read(iprot)
586
    iprot.readMessageEnd()
587
    result = updateTicket_result()
3376 rajveer 588
    self._handler.updateTicket(args.ticket, args.activity)
3131 rajveer 589
    oprot.writeMessageBegin("updateTicket", TMessageType.REPLY, seqid)
590
    result.write(oprot)
591
    oprot.writeMessageEnd()
592
    oprot.trans.flush()
593
 
594
  def process_insertTicket(self, seqid, iprot, oprot):
595
    args = insertTicket_args()
596
    args.read(iprot)
597
    iprot.readMessageEnd()
598
    result = insertTicket_result()
3376 rajveer 599
    result.success = self._handler.insertTicket(args.ticket, args.activity)
3131 rajveer 600
    oprot.writeMessageBegin("insertTicket", TMessageType.REPLY, seqid)
601
    result.write(oprot)
602
    oprot.writeMessageEnd()
603
    oprot.trans.flush()
604
 
605
  def process_getActivities(self, seqid, iprot, oprot):
606
    args = getActivities_args()
607
    args.read(iprot)
608
    iprot.readMessageEnd()
609
    result = getActivities_result()
3431 rajveer 610
    result.success = self._handler.getActivities(args.searchFilter)
3131 rajveer 611
    oprot.writeMessageBegin("getActivities", TMessageType.REPLY, seqid)
612
    result.write(oprot)
613
    oprot.writeMessageEnd()
614
    oprot.trans.flush()
615
 
616
  def process_insertActivity(self, seqid, iprot, oprot):
617
    args = insertActivity_args()
618
    args.read(iprot)
619
    iprot.readMessageEnd()
620
    result = insertActivity_result()
3431 rajveer 621
    result.success = self._handler.insertActivity(args.activity)
3131 rajveer 622
    oprot.writeMessageBegin("insertActivity", TMessageType.REPLY, seqid)
623
    result.write(oprot)
624
    oprot.writeMessageEnd()
625
    oprot.trans.flush()
626
 
3431 rajveer 627
  def process_markAsRead(self, seqid, iprot, oprot):
628
    args = markAsRead_args()
3131 rajveer 629
    args.read(iprot)
630
    iprot.readMessageEnd()
3431 rajveer 631
    result = markAsRead_result()
632
    self._handler.markAsRead(args.activityId, args.agentId)
633
    oprot.writeMessageBegin("markAsRead", TMessageType.REPLY, seqid)
3131 rajveer 634
    result.write(oprot)
635
    oprot.writeMessageEnd()
636
    oprot.trans.flush()
637
 
3431 rajveer 638
  def process_getAgents(self, seqid, iprot, oprot):
639
    args = getAgents_args()
3131 rajveer 640
    args.read(iprot)
641
    iprot.readMessageEnd()
3431 rajveer 642
    result = getAgents_result()
643
    result.success = self._handler.getAgents(args.searchFilter)
644
    oprot.writeMessageBegin("getAgents", TMessageType.REPLY, seqid)
3131 rajveer 645
    result.write(oprot)
646
    oprot.writeMessageEnd()
647
    oprot.trans.flush()
648
 
649
  def process_updatePasswordForAgent(self, seqid, iprot, oprot):
650
    args = updatePasswordForAgent_args()
651
    args.read(iprot)
652
    iprot.readMessageEnd()
653
    result = updatePasswordForAgent_result()
654
    self._handler.updatePasswordForAgent(args.agentEmailId, args.password)
655
    oprot.writeMessageBegin("updatePasswordForAgent", TMessageType.REPLY, seqid)
656
    result.write(oprot)
657
    oprot.writeMessageEnd()
658
    oprot.trans.flush()
659
 
660
  def process_getRoleNamesForAgent(self, seqid, iprot, oprot):
661
    args = getRoleNamesForAgent_args()
662
    args.read(iprot)
663
    iprot.readMessageEnd()
664
    result = getRoleNamesForAgent_result()
665
    result.success = self._handler.getRoleNamesForAgent(args.agentEmailId)
666
    oprot.writeMessageBegin("getRoleNamesForAgent", TMessageType.REPLY, seqid)
667
    result.write(oprot)
668
    oprot.writeMessageEnd()
669
    oprot.trans.flush()
670
 
671
  def process_getPermissionsForRoleName(self, seqid, iprot, oprot):
672
    args = getPermissionsForRoleName_args()
673
    args.read(iprot)
674
    iprot.readMessageEnd()
675
    result = getPermissionsForRoleName_result()
676
    result.success = self._handler.getPermissionsForRoleName(args.roleName)
677
    oprot.writeMessageBegin("getPermissionsForRoleName", TMessageType.REPLY, seqid)
678
    result.write(oprot)
679
    oprot.writeMessageEnd()
680
    oprot.trans.flush()
681
 
3376 rajveer 682
  def process_getLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
683
    args = getLastEmailProcessedTimestamp_args()
684
    args.read(iprot)
685
    iprot.readMessageEnd()
686
    result = getLastEmailProcessedTimestamp_result()
687
    result.success = self._handler.getLastEmailProcessedTimestamp()
688
    oprot.writeMessageBegin("getLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
689
    result.write(oprot)
690
    oprot.writeMessageEnd()
691
    oprot.trans.flush()
3131 rajveer 692
 
3376 rajveer 693
  def process_updateLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
694
    args = updateLastEmailProcessedTimestamp_args()
695
    args.read(iprot)
696
    iprot.readMessageEnd()
697
    result = updateLastEmailProcessedTimestamp_result()
698
    self._handler.updateLastEmailProcessedTimestamp(args.timestamp)
699
    oprot.writeMessageBegin("updateLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
700
    result.write(oprot)
701
    oprot.writeMessageEnd()
702
    oprot.trans.flush()
703
 
3499 mandeep.dh 704
  def process_processCODTxn(self, seqid, iprot, oprot):
705
    args = processCODTxn_args()
706
    args.read(iprot)
707
    iprot.readMessageEnd()
708
    result = processCODTxn_result()
709
    self._handler.processCODTxn(args.transactionId)
710
    oprot.writeMessageBegin("processCODTxn", TMessageType.REPLY, seqid)
711
    result.write(oprot)
712
    oprot.writeMessageEnd()
713
    oprot.trans.flush()
3376 rajveer 714
 
3499 mandeep.dh 715
 
3131 rajveer 716
# HELPER FUNCTIONS AND STRUCTURES
717
 
718
class getTickets_args:
719
  """
720
  Attributes:
3431 rajveer 721
   - searchFilter
3131 rajveer 722
  """
723
 
724
  thrift_spec = (
725
    None, # 0
3431 rajveer 726
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 727
  )
728
 
3431 rajveer 729
  def __init__(self, searchFilter=None,):
730
    self.searchFilter = searchFilter
3131 rajveer 731
 
732
  def read(self, iprot):
733
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
734
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
735
      return
736
    iprot.readStructBegin()
737
    while True:
738
      (fname, ftype, fid) = iprot.readFieldBegin()
739
      if ftype == TType.STOP:
740
        break
741
      if fid == 1:
3431 rajveer 742
        if ftype == TType.STRUCT:
743
          self.searchFilter = SearchFilter()
744
          self.searchFilter.read(iprot)
3131 rajveer 745
        else:
746
          iprot.skip(ftype)
747
      else:
748
        iprot.skip(ftype)
749
      iprot.readFieldEnd()
750
    iprot.readStructEnd()
751
 
752
  def write(self, oprot):
753
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
754
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
755
      return
756
    oprot.writeStructBegin('getTickets_args')
3431 rajveer 757
    if self.searchFilter is not None:
758
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
759
      self.searchFilter.write(oprot)
3131 rajveer 760
      oprot.writeFieldEnd()
761
    oprot.writeFieldStop()
762
    oprot.writeStructEnd()
763
 
3431 rajveer 764
  def validate(self):
765
    return
3131 rajveer 766
 
767
 
768
  def __repr__(self):
769
    L = ['%s=%r' % (key, value)
770
      for key, value in self.__dict__.iteritems()]
771
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
772
 
773
  def __eq__(self, other):
774
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
775
 
776
  def __ne__(self, other):
777
    return not (self == other)
778
 
3431 rajveer 779
class getTickets_result:
3131 rajveer 780
  """
781
  Attributes:
782
   - success
783
  """
784
 
785
  thrift_spec = (
786
    (0, TType.LIST, 'success', (TType.STRUCT,(Ticket, Ticket.thrift_spec)), None, ), # 0
787
  )
788
 
789
  def __init__(self, success=None,):
790
    self.success = success
791
 
792
  def read(self, iprot):
793
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
794
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
795
      return
796
    iprot.readStructBegin()
797
    while True:
798
      (fname, ftype, fid) = iprot.readFieldBegin()
799
      if ftype == TType.STOP:
800
        break
801
      if fid == 0:
802
        if ftype == TType.LIST:
803
          self.success = []
804
          (_etype17, _size14) = iprot.readListBegin()
805
          for _i18 in xrange(_size14):
806
            _elem19 = Ticket()
807
            _elem19.read(iprot)
808
            self.success.append(_elem19)
809
          iprot.readListEnd()
810
        else:
811
          iprot.skip(ftype)
812
      else:
813
        iprot.skip(ftype)
814
      iprot.readFieldEnd()
815
    iprot.readStructEnd()
816
 
817
  def write(self, oprot):
818
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
819
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
820
      return
3431 rajveer 821
    oprot.writeStructBegin('getTickets_result')
822
    if self.success is not None:
3131 rajveer 823
      oprot.writeFieldBegin('success', TType.LIST, 0)
824
      oprot.writeListBegin(TType.STRUCT, len(self.success))
825
      for iter20 in self.success:
826
        iter20.write(oprot)
827
      oprot.writeListEnd()
828
      oprot.writeFieldEnd()
829
    oprot.writeFieldStop()
830
    oprot.writeStructEnd()
831
 
3431 rajveer 832
  def validate(self):
833
    return
834
 
835
 
3131 rajveer 836
  def __repr__(self):
837
    L = ['%s=%r' % (key, value)
838
      for key, value in self.__dict__.iteritems()]
839
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
840
 
841
  def __eq__(self, other):
842
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
843
 
844
  def __ne__(self, other):
845
    return not (self == other)
846
 
3431 rajveer 847
class getUnassignedTickets_args:
3376 rajveer 848
 
849
  thrift_spec = (
850
  )
851
 
852
  def read(self, iprot):
853
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
854
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
855
      return
856
    iprot.readStructBegin()
857
    while True:
858
      (fname, ftype, fid) = iprot.readFieldBegin()
859
      if ftype == TType.STOP:
860
        break
861
      else:
862
        iprot.skip(ftype)
863
      iprot.readFieldEnd()
864
    iprot.readStructEnd()
865
 
866
  def write(self, oprot):
867
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
868
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
869
      return
3431 rajveer 870
    oprot.writeStructBegin('getUnassignedTickets_args')
3376 rajveer 871
    oprot.writeFieldStop()
872
    oprot.writeStructEnd()
873
 
3431 rajveer 874
  def validate(self):
875
    return
876
 
877
 
3376 rajveer 878
  def __repr__(self):
879
    L = ['%s=%r' % (key, value)
880
      for key, value in self.__dict__.iteritems()]
881
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
882
 
883
  def __eq__(self, other):
884
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
885
 
886
  def __ne__(self, other):
887
    return not (self == other)
888
 
3431 rajveer 889
class getUnassignedTickets_result:
3376 rajveer 890
  """
891
  Attributes:
892
   - success
893
  """
894
 
895
  thrift_spec = (
896
    (0, TType.LIST, 'success', (TType.STRUCT,(Ticket, Ticket.thrift_spec)), None, ), # 0
897
  )
898
 
899
  def __init__(self, success=None,):
900
    self.success = success
901
 
902
  def read(self, iprot):
903
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
904
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
905
      return
906
    iprot.readStructBegin()
907
    while True:
908
      (fname, ftype, fid) = iprot.readFieldBegin()
909
      if ftype == TType.STOP:
910
        break
911
      if fid == 0:
912
        if ftype == TType.LIST:
913
          self.success = []
914
          (_etype24, _size21) = iprot.readListBegin()
915
          for _i25 in xrange(_size21):
916
            _elem26 = Ticket()
917
            _elem26.read(iprot)
918
            self.success.append(_elem26)
919
          iprot.readListEnd()
920
        else:
921
          iprot.skip(ftype)
922
      else:
923
        iprot.skip(ftype)
924
      iprot.readFieldEnd()
925
    iprot.readStructEnd()
926
 
927
  def write(self, oprot):
928
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
929
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
930
      return
3431 rajveer 931
    oprot.writeStructBegin('getUnassignedTickets_result')
932
    if self.success is not None:
3376 rajveer 933
      oprot.writeFieldBegin('success', TType.LIST, 0)
934
      oprot.writeListBegin(TType.STRUCT, len(self.success))
935
      for iter27 in self.success:
936
        iter27.write(oprot)
937
      oprot.writeListEnd()
938
      oprot.writeFieldEnd()
939
    oprot.writeFieldStop()
940
    oprot.writeStructEnd()
941
 
3431 rajveer 942
  def validate(self):
943
    return
3376 rajveer 944
 
945
 
3131 rajveer 946
  def __repr__(self):
947
    L = ['%s=%r' % (key, value)
948
      for key, value in self.__dict__.iteritems()]
949
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
950
 
951
  def __eq__(self, other):
952
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
953
 
954
  def __ne__(self, other):
955
    return not (self == other)
956
 
957
class updateTicket_args:
958
  """
959
  Attributes:
960
   - ticket
3376 rajveer 961
   - activity
3131 rajveer 962
  """
963
 
964
  thrift_spec = (
965
    None, # 0
966
    (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
3376 rajveer 967
    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
3131 rajveer 968
  )
969
 
3376 rajveer 970
  def __init__(self, ticket=None, activity=None,):
3131 rajveer 971
    self.ticket = ticket
3376 rajveer 972
    self.activity = activity
3131 rajveer 973
 
974
  def read(self, iprot):
975
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
976
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
977
      return
978
    iprot.readStructBegin()
979
    while True:
980
      (fname, ftype, fid) = iprot.readFieldBegin()
981
      if ftype == TType.STOP:
982
        break
983
      if fid == 1:
984
        if ftype == TType.STRUCT:
985
          self.ticket = Ticket()
986
          self.ticket.read(iprot)
987
        else:
988
          iprot.skip(ftype)
3376 rajveer 989
      elif fid == 2:
990
        if ftype == TType.STRUCT:
991
          self.activity = Activity()
992
          self.activity.read(iprot)
993
        else:
994
          iprot.skip(ftype)
3131 rajveer 995
      else:
996
        iprot.skip(ftype)
997
      iprot.readFieldEnd()
998
    iprot.readStructEnd()
999
 
1000
  def write(self, oprot):
1001
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1002
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1003
      return
1004
    oprot.writeStructBegin('updateTicket_args')
3431 rajveer 1005
    if self.ticket is not None:
3131 rajveer 1006
      oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
1007
      self.ticket.write(oprot)
1008
      oprot.writeFieldEnd()
3431 rajveer 1009
    if self.activity is not None:
3376 rajveer 1010
      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
1011
      self.activity.write(oprot)
1012
      oprot.writeFieldEnd()
3131 rajveer 1013
    oprot.writeFieldStop()
1014
    oprot.writeStructEnd()
1015
 
3431 rajveer 1016
  def validate(self):
1017
    return
1018
 
1019
 
3131 rajveer 1020
  def __repr__(self):
1021
    L = ['%s=%r' % (key, value)
1022
      for key, value in self.__dict__.iteritems()]
1023
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1024
 
1025
  def __eq__(self, other):
1026
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1027
 
1028
  def __ne__(self, other):
1029
    return not (self == other)
1030
 
1031
class updateTicket_result:
1032
 
1033
  thrift_spec = (
1034
  )
1035
 
1036
  def read(self, iprot):
1037
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1038
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1039
      return
1040
    iprot.readStructBegin()
1041
    while True:
1042
      (fname, ftype, fid) = iprot.readFieldBegin()
1043
      if ftype == TType.STOP:
1044
        break
1045
      else:
1046
        iprot.skip(ftype)
1047
      iprot.readFieldEnd()
1048
    iprot.readStructEnd()
1049
 
1050
  def write(self, oprot):
1051
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1052
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1053
      return
1054
    oprot.writeStructBegin('updateTicket_result')
1055
    oprot.writeFieldStop()
1056
    oprot.writeStructEnd()
1057
 
3431 rajveer 1058
  def validate(self):
1059
    return
1060
 
1061
 
3131 rajveer 1062
  def __repr__(self):
1063
    L = ['%s=%r' % (key, value)
1064
      for key, value in self.__dict__.iteritems()]
1065
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1066
 
1067
  def __eq__(self, other):
1068
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1069
 
1070
  def __ne__(self, other):
1071
    return not (self == other)
1072
 
1073
class insertTicket_args:
1074
  """
1075
  Attributes:
1076
   - ticket
3376 rajveer 1077
   - activity
3131 rajveer 1078
  """
1079
 
1080
  thrift_spec = (
1081
    None, # 0
1082
    (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
3376 rajveer 1083
    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
3131 rajveer 1084
  )
1085
 
3376 rajveer 1086
  def __init__(self, ticket=None, activity=None,):
3131 rajveer 1087
    self.ticket = ticket
3376 rajveer 1088
    self.activity = activity
3131 rajveer 1089
 
1090
  def read(self, iprot):
1091
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1092
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1093
      return
1094
    iprot.readStructBegin()
1095
    while True:
1096
      (fname, ftype, fid) = iprot.readFieldBegin()
1097
      if ftype == TType.STOP:
1098
        break
1099
      if fid == 1:
1100
        if ftype == TType.STRUCT:
1101
          self.ticket = Ticket()
1102
          self.ticket.read(iprot)
1103
        else:
1104
          iprot.skip(ftype)
3376 rajveer 1105
      elif fid == 2:
1106
        if ftype == TType.STRUCT:
1107
          self.activity = Activity()
1108
          self.activity.read(iprot)
1109
        else:
1110
          iprot.skip(ftype)
3131 rajveer 1111
      else:
1112
        iprot.skip(ftype)
1113
      iprot.readFieldEnd()
1114
    iprot.readStructEnd()
1115
 
1116
  def write(self, oprot):
1117
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1118
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1119
      return
1120
    oprot.writeStructBegin('insertTicket_args')
3431 rajveer 1121
    if self.ticket is not None:
3131 rajveer 1122
      oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
1123
      self.ticket.write(oprot)
1124
      oprot.writeFieldEnd()
3431 rajveer 1125
    if self.activity is not None:
3376 rajveer 1126
      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
1127
      self.activity.write(oprot)
1128
      oprot.writeFieldEnd()
3131 rajveer 1129
    oprot.writeFieldStop()
1130
    oprot.writeStructEnd()
1131
 
3431 rajveer 1132
  def validate(self):
1133
    return
1134
 
1135
 
3131 rajveer 1136
  def __repr__(self):
1137
    L = ['%s=%r' % (key, value)
1138
      for key, value in self.__dict__.iteritems()]
1139
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1140
 
1141
  def __eq__(self, other):
1142
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1143
 
1144
  def __ne__(self, other):
1145
    return not (self == other)
1146
 
1147
class insertTicket_result:
1148
  """
1149
  Attributes:
1150
   - success
1151
  """
1152
 
1153
  thrift_spec = (
1154
    (0, TType.I64, 'success', None, None, ), # 0
1155
  )
1156
 
1157
  def __init__(self, success=None,):
1158
    self.success = success
1159
 
1160
  def read(self, iprot):
1161
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1162
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1163
      return
1164
    iprot.readStructBegin()
1165
    while True:
1166
      (fname, ftype, fid) = iprot.readFieldBegin()
1167
      if ftype == TType.STOP:
1168
        break
1169
      if fid == 0:
1170
        if ftype == TType.I64:
1171
          self.success = iprot.readI64();
1172
        else:
1173
          iprot.skip(ftype)
1174
      else:
1175
        iprot.skip(ftype)
1176
      iprot.readFieldEnd()
1177
    iprot.readStructEnd()
1178
 
1179
  def write(self, oprot):
1180
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1181
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1182
      return
1183
    oprot.writeStructBegin('insertTicket_result')
3431 rajveer 1184
    if self.success is not None:
3131 rajveer 1185
      oprot.writeFieldBegin('success', TType.I64, 0)
1186
      oprot.writeI64(self.success)
1187
      oprot.writeFieldEnd()
1188
    oprot.writeFieldStop()
1189
    oprot.writeStructEnd()
1190
 
3431 rajveer 1191
  def validate(self):
1192
    return
1193
 
1194
 
3131 rajveer 1195
  def __repr__(self):
1196
    L = ['%s=%r' % (key, value)
1197
      for key, value in self.__dict__.iteritems()]
1198
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1199
 
1200
  def __eq__(self, other):
1201
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1202
 
1203
  def __ne__(self, other):
1204
    return not (self == other)
1205
 
1206
class getActivities_args:
1207
  """
1208
  Attributes:
3431 rajveer 1209
   - searchFilter
3131 rajveer 1210
  """
1211
 
1212
  thrift_spec = (
1213
    None, # 0
3431 rajveer 1214
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 1215
  )
1216
 
3431 rajveer 1217
  def __init__(self, searchFilter=None,):
1218
    self.searchFilter = searchFilter
3131 rajveer 1219
 
1220
  def read(self, iprot):
1221
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1222
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1223
      return
1224
    iprot.readStructBegin()
1225
    while True:
1226
      (fname, ftype, fid) = iprot.readFieldBegin()
1227
      if ftype == TType.STOP:
1228
        break
1229
      if fid == 1:
3431 rajveer 1230
        if ftype == TType.STRUCT:
1231
          self.searchFilter = SearchFilter()
1232
          self.searchFilter.read(iprot)
3131 rajveer 1233
        else:
1234
          iprot.skip(ftype)
1235
      else:
1236
        iprot.skip(ftype)
1237
      iprot.readFieldEnd()
1238
    iprot.readStructEnd()
1239
 
1240
  def write(self, oprot):
1241
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1242
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1243
      return
1244
    oprot.writeStructBegin('getActivities_args')
3431 rajveer 1245
    if self.searchFilter is not None:
1246
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
1247
      self.searchFilter.write(oprot)
3131 rajveer 1248
      oprot.writeFieldEnd()
1249
    oprot.writeFieldStop()
1250
    oprot.writeStructEnd()
1251
 
3431 rajveer 1252
  def validate(self):
1253
    return
1254
 
1255
 
3131 rajveer 1256
  def __repr__(self):
1257
    L = ['%s=%r' % (key, value)
1258
      for key, value in self.__dict__.iteritems()]
1259
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1260
 
1261
  def __eq__(self, other):
1262
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1263
 
1264
  def __ne__(self, other):
1265
    return not (self == other)
1266
 
1267
class getActivities_result:
1268
  """
1269
  Attributes:
1270
   - success
1271
  """
1272
 
1273
  thrift_spec = (
1274
    (0, TType.LIST, 'success', (TType.STRUCT,(Activity, Activity.thrift_spec)), None, ), # 0
1275
  )
1276
 
1277
  def __init__(self, success=None,):
1278
    self.success = success
1279
 
1280
  def read(self, iprot):
1281
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1282
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1283
      return
1284
    iprot.readStructBegin()
1285
    while True:
1286
      (fname, ftype, fid) = iprot.readFieldBegin()
1287
      if ftype == TType.STOP:
1288
        break
1289
      if fid == 0:
1290
        if ftype == TType.LIST:
1291
          self.success = []
3376 rajveer 1292
          (_etype31, _size28) = iprot.readListBegin()
1293
          for _i32 in xrange(_size28):
1294
            _elem33 = Activity()
1295
            _elem33.read(iprot)
1296
            self.success.append(_elem33)
3131 rajveer 1297
          iprot.readListEnd()
1298
        else:
1299
          iprot.skip(ftype)
1300
      else:
1301
        iprot.skip(ftype)
1302
      iprot.readFieldEnd()
1303
    iprot.readStructEnd()
1304
 
1305
  def write(self, oprot):
1306
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1307
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1308
      return
1309
    oprot.writeStructBegin('getActivities_result')
3431 rajveer 1310
    if self.success is not None:
3131 rajveer 1311
      oprot.writeFieldBegin('success', TType.LIST, 0)
1312
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3376 rajveer 1313
      for iter34 in self.success:
1314
        iter34.write(oprot)
3131 rajveer 1315
      oprot.writeListEnd()
1316
      oprot.writeFieldEnd()
1317
    oprot.writeFieldStop()
1318
    oprot.writeStructEnd()
1319
 
3431 rajveer 1320
  def validate(self):
1321
    return
1322
 
1323
 
3131 rajveer 1324
  def __repr__(self):
1325
    L = ['%s=%r' % (key, value)
1326
      for key, value in self.__dict__.iteritems()]
1327
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1328
 
1329
  def __eq__(self, other):
1330
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1331
 
1332
  def __ne__(self, other):
1333
    return not (self == other)
1334
 
3431 rajveer 1335
class insertActivity_args:
3376 rajveer 1336
  """
1337
  Attributes:
3431 rajveer 1338
   - activity
3376 rajveer 1339
  """
1340
 
1341
  thrift_spec = (
1342
    None, # 0
3431 rajveer 1343
    (1, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 1
3376 rajveer 1344
  )
1345
 
3431 rajveer 1346
  def __init__(self, activity=None,):
1347
    self.activity = activity
3376 rajveer 1348
 
1349
  def read(self, iprot):
1350
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1351
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1352
      return
1353
    iprot.readStructBegin()
1354
    while True:
1355
      (fname, ftype, fid) = iprot.readFieldBegin()
1356
      if ftype == TType.STOP:
1357
        break
1358
      if fid == 1:
3431 rajveer 1359
        if ftype == TType.STRUCT:
1360
          self.activity = Activity()
1361
          self.activity.read(iprot)
3376 rajveer 1362
        else:
1363
          iprot.skip(ftype)
1364
      else:
1365
        iprot.skip(ftype)
1366
      iprot.readFieldEnd()
1367
    iprot.readStructEnd()
1368
 
1369
  def write(self, oprot):
1370
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1371
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1372
      return
3431 rajveer 1373
    oprot.writeStructBegin('insertActivity_args')
1374
    if self.activity is not None:
1375
      oprot.writeFieldBegin('activity', TType.STRUCT, 1)
1376
      self.activity.write(oprot)
3376 rajveer 1377
      oprot.writeFieldEnd()
1378
    oprot.writeFieldStop()
1379
    oprot.writeStructEnd()
1380
 
3431 rajveer 1381
  def validate(self):
1382
    return
1383
 
1384
 
3376 rajveer 1385
  def __repr__(self):
1386
    L = ['%s=%r' % (key, value)
1387
      for key, value in self.__dict__.iteritems()]
1388
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1389
 
1390
  def __eq__(self, other):
1391
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1392
 
1393
  def __ne__(self, other):
1394
    return not (self == other)
1395
 
3431 rajveer 1396
class insertActivity_result:
3376 rajveer 1397
  """
1398
  Attributes:
1399
   - success
1400
  """
1401
 
1402
  thrift_spec = (
3431 rajveer 1403
    (0, TType.I64, 'success', None, None, ), # 0
3376 rajveer 1404
  )
1405
 
1406
  def __init__(self, success=None,):
1407
    self.success = success
1408
 
1409
  def read(self, iprot):
1410
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1411
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1412
      return
1413
    iprot.readStructBegin()
1414
    while True:
1415
      (fname, ftype, fid) = iprot.readFieldBegin()
1416
      if ftype == TType.STOP:
1417
        break
1418
      if fid == 0:
3131 rajveer 1419
        if ftype == TType.I64:
3431 rajveer 1420
          self.success = iprot.readI64();
3131 rajveer 1421
        else:
1422
          iprot.skip(ftype)
1423
      else:
1424
        iprot.skip(ftype)
1425
      iprot.readFieldEnd()
1426
    iprot.readStructEnd()
1427
 
1428
  def write(self, oprot):
1429
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1430
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1431
      return
3431 rajveer 1432
    oprot.writeStructBegin('insertActivity_result')
1433
    if self.success is not None:
1434
      oprot.writeFieldBegin('success', TType.I64, 0)
1435
      oprot.writeI64(self.success)
3131 rajveer 1436
      oprot.writeFieldEnd()
1437
    oprot.writeFieldStop()
1438
    oprot.writeStructEnd()
1439
 
3431 rajveer 1440
  def validate(self):
1441
    return
3131 rajveer 1442
 
1443
 
1444
  def __repr__(self):
1445
    L = ['%s=%r' % (key, value)
1446
      for key, value in self.__dict__.iteritems()]
1447
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1448
 
1449
  def __eq__(self, other):
1450
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1451
 
1452
  def __ne__(self, other):
1453
    return not (self == other)
1454
 
3431 rajveer 1455
class markAsRead_args:
3131 rajveer 1456
  """
1457
  Attributes:
1458
   - activityId
3431 rajveer 1459
   - agentId
3131 rajveer 1460
  """
1461
 
1462
  thrift_spec = (
1463
    None, # 0
1464
    (1, TType.I64, 'activityId', None, None, ), # 1
3431 rajveer 1465
    (2, TType.I64, 'agentId', None, None, ), # 2
3131 rajveer 1466
  )
1467
 
3431 rajveer 1468
  def __init__(self, activityId=None, agentId=None,):
3131 rajveer 1469
    self.activityId = activityId
3431 rajveer 1470
    self.agentId = agentId
3131 rajveer 1471
 
1472
  def read(self, iprot):
1473
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1474
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1475
      return
1476
    iprot.readStructBegin()
1477
    while True:
1478
      (fname, ftype, fid) = iprot.readFieldBegin()
1479
      if ftype == TType.STOP:
1480
        break
1481
      if fid == 1:
1482
        if ftype == TType.I64:
1483
          self.activityId = iprot.readI64();
1484
        else:
1485
          iprot.skip(ftype)
3431 rajveer 1486
      elif fid == 2:
1487
        if ftype == TType.I64:
1488
          self.agentId = iprot.readI64();
1489
        else:
1490
          iprot.skip(ftype)
3131 rajveer 1491
      else:
1492
        iprot.skip(ftype)
1493
      iprot.readFieldEnd()
1494
    iprot.readStructEnd()
1495
 
1496
  def write(self, oprot):
1497
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1498
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1499
      return
3431 rajveer 1500
    oprot.writeStructBegin('markAsRead_args')
1501
    if self.activityId is not None:
3131 rajveer 1502
      oprot.writeFieldBegin('activityId', TType.I64, 1)
1503
      oprot.writeI64(self.activityId)
1504
      oprot.writeFieldEnd()
3431 rajveer 1505
    if self.agentId is not None:
1506
      oprot.writeFieldBegin('agentId', TType.I64, 2)
1507
      oprot.writeI64(self.agentId)
1508
      oprot.writeFieldEnd()
3131 rajveer 1509
    oprot.writeFieldStop()
1510
    oprot.writeStructEnd()
1511
 
3431 rajveer 1512
  def validate(self):
1513
    return
3131 rajveer 1514
 
1515
 
1516
  def __repr__(self):
1517
    L = ['%s=%r' % (key, value)
1518
      for key, value in self.__dict__.iteritems()]
1519
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1520
 
1521
  def __eq__(self, other):
1522
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1523
 
1524
  def __ne__(self, other):
1525
    return not (self == other)
1526
 
3431 rajveer 1527
class markAsRead_result:
3131 rajveer 1528
 
1529
  thrift_spec = (
1530
  )
1531
 
1532
  def read(self, iprot):
1533
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1534
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1535
      return
1536
    iprot.readStructBegin()
1537
    while True:
1538
      (fname, ftype, fid) = iprot.readFieldBegin()
1539
      if ftype == TType.STOP:
1540
        break
1541
      else:
1542
        iprot.skip(ftype)
1543
      iprot.readFieldEnd()
1544
    iprot.readStructEnd()
1545
 
1546
  def write(self, oprot):
1547
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1548
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1549
      return
3431 rajveer 1550
    oprot.writeStructBegin('markAsRead_result')
3131 rajveer 1551
    oprot.writeFieldStop()
1552
    oprot.writeStructEnd()
1553
 
3431 rajveer 1554
  def validate(self):
1555
    return
3131 rajveer 1556
 
1557
 
1558
  def __repr__(self):
1559
    L = ['%s=%r' % (key, value)
1560
      for key, value in self.__dict__.iteritems()]
1561
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1562
 
1563
  def __eq__(self, other):
1564
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1565
 
1566
  def __ne__(self, other):
1567
    return not (self == other)
1568
 
3431 rajveer 1569
class getAgents_args:
3131 rajveer 1570
  """
1571
  Attributes:
3431 rajveer 1572
   - searchFilter
3131 rajveer 1573
  """
1574
 
1575
  thrift_spec = (
1576
    None, # 0
3431 rajveer 1577
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 1578
  )
1579
 
3431 rajveer 1580
  def __init__(self, searchFilter=None,):
1581
    self.searchFilter = searchFilter
3131 rajveer 1582
 
1583
  def read(self, iprot):
1584
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1585
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1586
      return
1587
    iprot.readStructBegin()
1588
    while True:
1589
      (fname, ftype, fid) = iprot.readFieldBegin()
1590
      if ftype == TType.STOP:
1591
        break
1592
      if fid == 1:
1593
        if ftype == TType.STRUCT:
3431 rajveer 1594
          self.searchFilter = SearchFilter()
1595
          self.searchFilter.read(iprot)
3131 rajveer 1596
        else:
1597
          iprot.skip(ftype)
1598
      else:
1599
        iprot.skip(ftype)
1600
      iprot.readFieldEnd()
1601
    iprot.readStructEnd()
1602
 
1603
  def write(self, oprot):
1604
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1605
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1606
      return
3431 rajveer 1607
    oprot.writeStructBegin('getAgents_args')
1608
    if self.searchFilter is not None:
1609
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
1610
      self.searchFilter.write(oprot)
3131 rajveer 1611
      oprot.writeFieldEnd()
1612
    oprot.writeFieldStop()
1613
    oprot.writeStructEnd()
1614
 
3431 rajveer 1615
  def validate(self):
1616
    return
3131 rajveer 1617
 
1618
 
1619
  def __repr__(self):
1620
    L = ['%s=%r' % (key, value)
1621
      for key, value in self.__dict__.iteritems()]
1622
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1623
 
1624
  def __eq__(self, other):
1625
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1626
 
1627
  def __ne__(self, other):
1628
    return not (self == other)
1629
 
3431 rajveer 1630
class getAgents_result:
3131 rajveer 1631
  """
1632
  Attributes:
1633
   - success
1634
  """
1635
 
1636
  thrift_spec = (
1637
    (0, TType.LIST, 'success', (TType.STRUCT,(Agent, Agent.thrift_spec)), None, ), # 0
1638
  )
1639
 
1640
  def __init__(self, success=None,):
1641
    self.success = success
1642
 
1643
  def read(self, iprot):
1644
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1645
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1646
      return
1647
    iprot.readStructBegin()
1648
    while True:
1649
      (fname, ftype, fid) = iprot.readFieldBegin()
1650
      if ftype == TType.STOP:
1651
        break
1652
      if fid == 0:
1653
        if ftype == TType.LIST:
1654
          self.success = []
3431 rajveer 1655
          (_etype38, _size35) = iprot.readListBegin()
1656
          for _i39 in xrange(_size35):
1657
            _elem40 = Agent()
1658
            _elem40.read(iprot)
1659
            self.success.append(_elem40)
3131 rajveer 1660
          iprot.readListEnd()
1661
        else:
1662
          iprot.skip(ftype)
1663
      else:
1664
        iprot.skip(ftype)
1665
      iprot.readFieldEnd()
1666
    iprot.readStructEnd()
1667
 
1668
  def write(self, oprot):
1669
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1670
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1671
      return
3431 rajveer 1672
    oprot.writeStructBegin('getAgents_result')
1673
    if self.success is not None:
3131 rajveer 1674
      oprot.writeFieldBegin('success', TType.LIST, 0)
1675
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3431 rajveer 1676
      for iter41 in self.success:
1677
        iter41.write(oprot)
3131 rajveer 1678
      oprot.writeListEnd()
1679
      oprot.writeFieldEnd()
1680
    oprot.writeFieldStop()
1681
    oprot.writeStructEnd()
1682
 
3431 rajveer 1683
  def validate(self):
1684
    return
3131 rajveer 1685
 
1686
 
1687
  def __repr__(self):
1688
    L = ['%s=%r' % (key, value)
1689
      for key, value in self.__dict__.iteritems()]
1690
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1691
 
1692
  def __eq__(self, other):
1693
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1694
 
1695
  def __ne__(self, other):
1696
    return not (self == other)
1697
 
1698
class updatePasswordForAgent_args:
1699
  """
1700
  Attributes:
1701
   - agentEmailId
1702
   - password
1703
  """
1704
 
1705
  thrift_spec = (
1706
    None, # 0
1707
    (1, TType.STRING, 'agentEmailId', None, None, ), # 1
1708
    (2, TType.STRING, 'password', None, None, ), # 2
1709
  )
1710
 
1711
  def __init__(self, agentEmailId=None, password=None,):
1712
    self.agentEmailId = agentEmailId
1713
    self.password = password
1714
 
1715
  def read(self, iprot):
1716
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1717
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1718
      return
1719
    iprot.readStructBegin()
1720
    while True:
1721
      (fname, ftype, fid) = iprot.readFieldBegin()
1722
      if ftype == TType.STOP:
1723
        break
1724
      if fid == 1:
1725
        if ftype == TType.STRING:
1726
          self.agentEmailId = iprot.readString();
1727
        else:
1728
          iprot.skip(ftype)
1729
      elif fid == 2:
1730
        if ftype == TType.STRING:
1731
          self.password = iprot.readString();
1732
        else:
1733
          iprot.skip(ftype)
1734
      else:
1735
        iprot.skip(ftype)
1736
      iprot.readFieldEnd()
1737
    iprot.readStructEnd()
1738
 
1739
  def write(self, oprot):
1740
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1741
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1742
      return
1743
    oprot.writeStructBegin('updatePasswordForAgent_args')
3431 rajveer 1744
    if self.agentEmailId is not None:
3131 rajveer 1745
      oprot.writeFieldBegin('agentEmailId', TType.STRING, 1)
1746
      oprot.writeString(self.agentEmailId)
1747
      oprot.writeFieldEnd()
3431 rajveer 1748
    if self.password is not None:
3131 rajveer 1749
      oprot.writeFieldBegin('password', TType.STRING, 2)
1750
      oprot.writeString(self.password)
1751
      oprot.writeFieldEnd()
1752
    oprot.writeFieldStop()
1753
    oprot.writeStructEnd()
1754
 
3431 rajveer 1755
  def validate(self):
1756
    return
1757
 
1758
 
3131 rajveer 1759
  def __repr__(self):
1760
    L = ['%s=%r' % (key, value)
1761
      for key, value in self.__dict__.iteritems()]
1762
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1763
 
1764
  def __eq__(self, other):
1765
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1766
 
1767
  def __ne__(self, other):
1768
    return not (self == other)
1769
 
1770
class updatePasswordForAgent_result:
1771
 
1772
  thrift_spec = (
1773
  )
1774
 
1775
  def read(self, iprot):
1776
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1777
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1778
      return
1779
    iprot.readStructBegin()
1780
    while True:
1781
      (fname, ftype, fid) = iprot.readFieldBegin()
1782
      if ftype == TType.STOP:
1783
        break
1784
      else:
1785
        iprot.skip(ftype)
1786
      iprot.readFieldEnd()
1787
    iprot.readStructEnd()
1788
 
1789
  def write(self, oprot):
1790
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1791
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1792
      return
1793
    oprot.writeStructBegin('updatePasswordForAgent_result')
1794
    oprot.writeFieldStop()
1795
    oprot.writeStructEnd()
1796
 
3431 rajveer 1797
  def validate(self):
1798
    return
1799
 
1800
 
3131 rajveer 1801
  def __repr__(self):
1802
    L = ['%s=%r' % (key, value)
1803
      for key, value in self.__dict__.iteritems()]
1804
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1805
 
1806
  def __eq__(self, other):
1807
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1808
 
1809
  def __ne__(self, other):
1810
    return not (self == other)
1811
 
1812
class getRoleNamesForAgent_args:
1813
  """
1814
  Attributes:
1815
   - agentEmailId
1816
  """
1817
 
1818
  thrift_spec = (
1819
    None, # 0
1820
    (1, TType.STRING, 'agentEmailId', None, None, ), # 1
1821
  )
1822
 
1823
  def __init__(self, agentEmailId=None,):
1824
    self.agentEmailId = agentEmailId
1825
 
1826
  def read(self, iprot):
1827
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1828
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1829
      return
1830
    iprot.readStructBegin()
1831
    while True:
1832
      (fname, ftype, fid) = iprot.readFieldBegin()
1833
      if ftype == TType.STOP:
1834
        break
1835
      if fid == 1:
1836
        if ftype == TType.STRING:
1837
          self.agentEmailId = iprot.readString();
1838
        else:
1839
          iprot.skip(ftype)
1840
      else:
1841
        iprot.skip(ftype)
1842
      iprot.readFieldEnd()
1843
    iprot.readStructEnd()
1844
 
1845
  def write(self, oprot):
1846
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1847
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1848
      return
1849
    oprot.writeStructBegin('getRoleNamesForAgent_args')
3431 rajveer 1850
    if self.agentEmailId is not None:
3131 rajveer 1851
      oprot.writeFieldBegin('agentEmailId', TType.STRING, 1)
1852
      oprot.writeString(self.agentEmailId)
1853
      oprot.writeFieldEnd()
1854
    oprot.writeFieldStop()
1855
    oprot.writeStructEnd()
1856
 
3431 rajveer 1857
  def validate(self):
1858
    return
1859
 
1860
 
3131 rajveer 1861
  def __repr__(self):
1862
    L = ['%s=%r' % (key, value)
1863
      for key, value in self.__dict__.iteritems()]
1864
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1865
 
1866
  def __eq__(self, other):
1867
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1868
 
1869
  def __ne__(self, other):
1870
    return not (self == other)
1871
 
1872
class getRoleNamesForAgent_result:
1873
  """
1874
  Attributes:
1875
   - success
1876
  """
1877
 
1878
  thrift_spec = (
1879
    (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
1880
  )
1881
 
1882
  def __init__(self, success=None,):
1883
    self.success = success
1884
 
1885
  def read(self, iprot):
1886
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1887
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1888
      return
1889
    iprot.readStructBegin()
1890
    while True:
1891
      (fname, ftype, fid) = iprot.readFieldBegin()
1892
      if ftype == TType.STOP:
1893
        break
1894
      if fid == 0:
1895
        if ftype == TType.LIST:
1896
          self.success = []
3431 rajveer 1897
          (_etype45, _size42) = iprot.readListBegin()
1898
          for _i46 in xrange(_size42):
1899
            _elem47 = iprot.readString();
1900
            self.success.append(_elem47)
3131 rajveer 1901
          iprot.readListEnd()
1902
        else:
1903
          iprot.skip(ftype)
1904
      else:
1905
        iprot.skip(ftype)
1906
      iprot.readFieldEnd()
1907
    iprot.readStructEnd()
1908
 
1909
  def write(self, oprot):
1910
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1911
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1912
      return
1913
    oprot.writeStructBegin('getRoleNamesForAgent_result')
3431 rajveer 1914
    if self.success is not None:
3131 rajveer 1915
      oprot.writeFieldBegin('success', TType.LIST, 0)
1916
      oprot.writeListBegin(TType.STRING, len(self.success))
3431 rajveer 1917
      for iter48 in self.success:
1918
        oprot.writeString(iter48)
3131 rajveer 1919
      oprot.writeListEnd()
1920
      oprot.writeFieldEnd()
1921
    oprot.writeFieldStop()
1922
    oprot.writeStructEnd()
1923
 
3431 rajveer 1924
  def validate(self):
1925
    return
1926
 
1927
 
3131 rajveer 1928
  def __repr__(self):
1929
    L = ['%s=%r' % (key, value)
1930
      for key, value in self.__dict__.iteritems()]
1931
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1932
 
1933
  def __eq__(self, other):
1934
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1935
 
1936
  def __ne__(self, other):
1937
    return not (self == other)
1938
 
1939
class getPermissionsForRoleName_args:
1940
  """
1941
  Attributes:
1942
   - roleName
1943
  """
1944
 
1945
  thrift_spec = (
1946
    None, # 0
1947
    (1, TType.STRING, 'roleName', None, None, ), # 1
1948
  )
1949
 
1950
  def __init__(self, roleName=None,):
1951
    self.roleName = roleName
1952
 
1953
  def read(self, iprot):
1954
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1955
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1956
      return
1957
    iprot.readStructBegin()
1958
    while True:
1959
      (fname, ftype, fid) = iprot.readFieldBegin()
1960
      if ftype == TType.STOP:
1961
        break
1962
      if fid == 1:
1963
        if ftype == TType.STRING:
1964
          self.roleName = iprot.readString();
1965
        else:
1966
          iprot.skip(ftype)
1967
      else:
1968
        iprot.skip(ftype)
1969
      iprot.readFieldEnd()
1970
    iprot.readStructEnd()
1971
 
1972
  def write(self, oprot):
1973
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1974
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1975
      return
1976
    oprot.writeStructBegin('getPermissionsForRoleName_args')
3431 rajveer 1977
    if self.roleName is not None:
3131 rajveer 1978
      oprot.writeFieldBegin('roleName', TType.STRING, 1)
1979
      oprot.writeString(self.roleName)
1980
      oprot.writeFieldEnd()
1981
    oprot.writeFieldStop()
1982
    oprot.writeStructEnd()
1983
 
3431 rajveer 1984
  def validate(self):
1985
    return
1986
 
1987
 
3131 rajveer 1988
  def __repr__(self):
1989
    L = ['%s=%r' % (key, value)
1990
      for key, value in self.__dict__.iteritems()]
1991
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1992
 
1993
  def __eq__(self, other):
1994
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1995
 
1996
  def __ne__(self, other):
1997
    return not (self == other)
1998
 
1999
class getPermissionsForRoleName_result:
2000
  """
2001
  Attributes:
2002
   - success
2003
  """
2004
 
2005
  thrift_spec = (
2006
    (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
2007
  )
2008
 
2009
  def __init__(self, success=None,):
2010
    self.success = success
2011
 
2012
  def read(self, iprot):
2013
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2014
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2015
      return
2016
    iprot.readStructBegin()
2017
    while True:
2018
      (fname, ftype, fid) = iprot.readFieldBegin()
2019
      if ftype == TType.STOP:
2020
        break
2021
      if fid == 0:
2022
        if ftype == TType.LIST:
2023
          self.success = []
3431 rajveer 2024
          (_etype52, _size49) = iprot.readListBegin()
2025
          for _i53 in xrange(_size49):
2026
            _elem54 = iprot.readString();
2027
            self.success.append(_elem54)
3131 rajveer 2028
          iprot.readListEnd()
2029
        else:
2030
          iprot.skip(ftype)
2031
      else:
2032
        iprot.skip(ftype)
2033
      iprot.readFieldEnd()
2034
    iprot.readStructEnd()
2035
 
2036
  def write(self, oprot):
2037
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2038
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2039
      return
2040
    oprot.writeStructBegin('getPermissionsForRoleName_result')
3431 rajveer 2041
    if self.success is not None:
3131 rajveer 2042
      oprot.writeFieldBegin('success', TType.LIST, 0)
2043
      oprot.writeListBegin(TType.STRING, len(self.success))
3431 rajveer 2044
      for iter55 in self.success:
2045
        oprot.writeString(iter55)
3131 rajveer 2046
      oprot.writeListEnd()
2047
      oprot.writeFieldEnd()
2048
    oprot.writeFieldStop()
2049
    oprot.writeStructEnd()
2050
 
3431 rajveer 2051
  def validate(self):
2052
    return
2053
 
2054
 
3131 rajveer 2055
  def __repr__(self):
2056
    L = ['%s=%r' % (key, value)
2057
      for key, value in self.__dict__.iteritems()]
2058
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2059
 
2060
  def __eq__(self, other):
2061
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2062
 
2063
  def __ne__(self, other):
2064
    return not (self == other)
2065
 
3376 rajveer 2066
class getLastEmailProcessedTimestamp_args:
3131 rajveer 2067
 
3376 rajveer 2068
  thrift_spec = (
2069
  )
2070
 
2071
  def read(self, iprot):
2072
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2073
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2074
      return
2075
    iprot.readStructBegin()
2076
    while True:
2077
      (fname, ftype, fid) = iprot.readFieldBegin()
2078
      if ftype == TType.STOP:
2079
        break
2080
      else:
2081
        iprot.skip(ftype)
2082
      iprot.readFieldEnd()
2083
    iprot.readStructEnd()
2084
 
2085
  def write(self, oprot):
2086
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2087
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2088
      return
2089
    oprot.writeStructBegin('getLastEmailProcessedTimestamp_args')
2090
    oprot.writeFieldStop()
2091
    oprot.writeStructEnd()
2092
 
3431 rajveer 2093
  def validate(self):
2094
    return
2095
 
2096
 
3376 rajveer 2097
  def __repr__(self):
2098
    L = ['%s=%r' % (key, value)
2099
      for key, value in self.__dict__.iteritems()]
2100
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2101
 
2102
  def __eq__(self, other):
2103
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2104
 
2105
  def __ne__(self, other):
2106
    return not (self == other)
2107
 
2108
class getLastEmailProcessedTimestamp_result:
2109
  """
2110
  Attributes:
2111
   - success
2112
  """
2113
 
2114
  thrift_spec = (
2115
    (0, TType.I64, 'success', None, None, ), # 0
2116
  )
2117
 
2118
  def __init__(self, success=None,):
2119
    self.success = success
2120
 
2121
  def read(self, iprot):
2122
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2123
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2124
      return
2125
    iprot.readStructBegin()
2126
    while True:
2127
      (fname, ftype, fid) = iprot.readFieldBegin()
2128
      if ftype == TType.STOP:
2129
        break
2130
      if fid == 0:
2131
        if ftype == TType.I64:
2132
          self.success = iprot.readI64();
2133
        else:
2134
          iprot.skip(ftype)
2135
      else:
2136
        iprot.skip(ftype)
2137
      iprot.readFieldEnd()
2138
    iprot.readStructEnd()
2139
 
2140
  def write(self, oprot):
2141
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2142
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2143
      return
2144
    oprot.writeStructBegin('getLastEmailProcessedTimestamp_result')
3431 rajveer 2145
    if self.success is not None:
3376 rajveer 2146
      oprot.writeFieldBegin('success', TType.I64, 0)
2147
      oprot.writeI64(self.success)
2148
      oprot.writeFieldEnd()
2149
    oprot.writeFieldStop()
2150
    oprot.writeStructEnd()
2151
 
3431 rajveer 2152
  def validate(self):
2153
    return
2154
 
2155
 
3376 rajveer 2156
  def __repr__(self):
2157
    L = ['%s=%r' % (key, value)
2158
      for key, value in self.__dict__.iteritems()]
2159
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2160
 
2161
  def __eq__(self, other):
2162
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2163
 
2164
  def __ne__(self, other):
2165
    return not (self == other)
2166
 
2167
class updateLastEmailProcessedTimestamp_args:
2168
  """
2169
  Attributes:
2170
   - timestamp
2171
  """
2172
 
2173
  thrift_spec = (
2174
    None, # 0
2175
    (1, TType.I64, 'timestamp', None, None, ), # 1
2176
  )
2177
 
2178
  def __init__(self, timestamp=None,):
2179
    self.timestamp = timestamp
2180
 
2181
  def read(self, iprot):
2182
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2183
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2184
      return
2185
    iprot.readStructBegin()
2186
    while True:
2187
      (fname, ftype, fid) = iprot.readFieldBegin()
2188
      if ftype == TType.STOP:
2189
        break
2190
      if fid == 1:
2191
        if ftype == TType.I64:
2192
          self.timestamp = iprot.readI64();
2193
        else:
2194
          iprot.skip(ftype)
2195
      else:
2196
        iprot.skip(ftype)
2197
      iprot.readFieldEnd()
2198
    iprot.readStructEnd()
2199
 
2200
  def write(self, oprot):
2201
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2202
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2203
      return
2204
    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_args')
3431 rajveer 2205
    if self.timestamp is not None:
3376 rajveer 2206
      oprot.writeFieldBegin('timestamp', TType.I64, 1)
2207
      oprot.writeI64(self.timestamp)
2208
      oprot.writeFieldEnd()
2209
    oprot.writeFieldStop()
2210
    oprot.writeStructEnd()
2211
 
3431 rajveer 2212
  def validate(self):
2213
    return
2214
 
2215
 
3376 rajveer 2216
  def __repr__(self):
2217
    L = ['%s=%r' % (key, value)
2218
      for key, value in self.__dict__.iteritems()]
2219
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2220
 
2221
  def __eq__(self, other):
2222
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2223
 
2224
  def __ne__(self, other):
2225
    return not (self == other)
2226
 
2227
class updateLastEmailProcessedTimestamp_result:
2228
 
2229
  thrift_spec = (
2230
  )
2231
 
2232
  def read(self, iprot):
2233
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2234
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2235
      return
2236
    iprot.readStructBegin()
2237
    while True:
2238
      (fname, ftype, fid) = iprot.readFieldBegin()
2239
      if ftype == TType.STOP:
2240
        break
2241
      else:
2242
        iprot.skip(ftype)
2243
      iprot.readFieldEnd()
2244
    iprot.readStructEnd()
2245
 
2246
  def write(self, oprot):
2247
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2248
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2249
      return
2250
    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_result')
2251
    oprot.writeFieldStop()
2252
    oprot.writeStructEnd()
2253
 
3431 rajveer 2254
  def validate(self):
2255
    return
2256
 
2257
 
3376 rajveer 2258
  def __repr__(self):
2259
    L = ['%s=%r' % (key, value)
2260
      for key, value in self.__dict__.iteritems()]
2261
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2262
 
2263
  def __eq__(self, other):
2264
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2265
 
2266
  def __ne__(self, other):
2267
    return not (self == other)
3499 mandeep.dh 2268
 
2269
class processCODTxn_args:
2270
  """
2271
  Attributes:
2272
   - transactionId
2273
  """
2274
 
2275
  thrift_spec = (
2276
    None, # 0
2277
    (1, TType.I64, 'transactionId', None, None, ), # 1
2278
  )
2279
 
2280
  def __init__(self, transactionId=None,):
2281
    self.transactionId = transactionId
2282
 
2283
  def read(self, iprot):
2284
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2285
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2286
      return
2287
    iprot.readStructBegin()
2288
    while True:
2289
      (fname, ftype, fid) = iprot.readFieldBegin()
2290
      if ftype == TType.STOP:
2291
        break
2292
      if fid == 1:
2293
        if ftype == TType.I64:
2294
          self.transactionId = iprot.readI64();
2295
        else:
2296
          iprot.skip(ftype)
2297
      else:
2298
        iprot.skip(ftype)
2299
      iprot.readFieldEnd()
2300
    iprot.readStructEnd()
2301
 
2302
  def write(self, oprot):
2303
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2304
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2305
      return
2306
    oprot.writeStructBegin('processCODTxn_args')
2307
    if self.transactionId is not None:
2308
      oprot.writeFieldBegin('transactionId', TType.I64, 1)
2309
      oprot.writeI64(self.transactionId)
2310
      oprot.writeFieldEnd()
2311
    oprot.writeFieldStop()
2312
    oprot.writeStructEnd()
2313
 
2314
  def validate(self):
2315
    return
2316
 
2317
 
2318
  def __repr__(self):
2319
    L = ['%s=%r' % (key, value)
2320
      for key, value in self.__dict__.iteritems()]
2321
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2322
 
2323
  def __eq__(self, other):
2324
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2325
 
2326
  def __ne__(self, other):
2327
    return not (self == other)
2328
 
2329
class processCODTxn_result:
2330
 
2331
  thrift_spec = (
2332
  )
2333
 
2334
  def read(self, iprot):
2335
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2336
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2337
      return
2338
    iprot.readStructBegin()
2339
    while True:
2340
      (fname, ftype, fid) = iprot.readFieldBegin()
2341
      if ftype == TType.STOP:
2342
        break
2343
      else:
2344
        iprot.skip(ftype)
2345
      iprot.readFieldEnd()
2346
    iprot.readStructEnd()
2347
 
2348
  def write(self, oprot):
2349
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2350
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2351
      return
2352
    oprot.writeStructBegin('processCODTxn_result')
2353
    oprot.writeFieldStop()
2354
    oprot.writeStructEnd()
2355
 
2356
  def validate(self):
2357
    return
2358
 
2359
 
2360
  def __repr__(self):
2361
    L = ['%s=%r' % (key, value)
2362
      for key, value in self.__dict__.iteritems()]
2363
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2364
 
2365
  def __eq__(self, other):
2366
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2367
 
2368
  def __ne__(self, other):
2369
    return not (self == other)