Subversion Repositories SmartDukaan

Rev

Rev 3499 | Rev 3546 | 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)
3376 rajveer 505
 
3499 mandeep.dh 506
  def send_processCODTxn(self, transactionId):
507
    self._oprot.writeMessageBegin('processCODTxn', TMessageType.CALL, self._seqid)
508
    args = processCODTxn_args()
509
    args.transactionId = transactionId
510
    args.write(self._oprot)
511
    self._oprot.writeMessageEnd()
512
    self._oprot.trans.flush()
513
 
3376 rajveer 514
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
3131 rajveer 515
  def __init__(self, handler):
3376 rajveer 516
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
3131 rajveer 517
    self._processMap["getTickets"] = Processor.process_getTickets
3376 rajveer 518
    self._processMap["getUnassignedTickets"] = Processor.process_getUnassignedTickets
3131 rajveer 519
    self._processMap["updateTicket"] = Processor.process_updateTicket
520
    self._processMap["insertTicket"] = Processor.process_insertTicket
521
    self._processMap["getActivities"] = Processor.process_getActivities
522
    self._processMap["insertActivity"] = Processor.process_insertActivity
3431 rajveer 523
    self._processMap["markAsRead"] = Processor.process_markAsRead
524
    self._processMap["getAgents"] = Processor.process_getAgents
3131 rajveer 525
    self._processMap["updatePasswordForAgent"] = Processor.process_updatePasswordForAgent
526
    self._processMap["getRoleNamesForAgent"] = Processor.process_getRoleNamesForAgent
527
    self._processMap["getPermissionsForRoleName"] = Processor.process_getPermissionsForRoleName
3376 rajveer 528
    self._processMap["getLastEmailProcessedTimestamp"] = Processor.process_getLastEmailProcessedTimestamp
529
    self._processMap["updateLastEmailProcessedTimestamp"] = Processor.process_updateLastEmailProcessedTimestamp
3499 mandeep.dh 530
    self._processMap["processCODTxn"] = Processor.process_processCODTxn
3131 rajveer 531
 
532
  def process(self, iprot, oprot):
533
    (name, type, seqid) = iprot.readMessageBegin()
534
    if name not in self._processMap:
535
      iprot.skip(TType.STRUCT)
536
      iprot.readMessageEnd()
537
      x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
538
      oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
539
      x.write(oprot)
540
      oprot.writeMessageEnd()
541
      oprot.trans.flush()
542
      return
543
    else:
544
      self._processMap[name](self, seqid, iprot, oprot)
545
    return True
546
 
547
  def process_getTickets(self, seqid, iprot, oprot):
548
    args = getTickets_args()
549
    args.read(iprot)
550
    iprot.readMessageEnd()
551
    result = getTickets_result()
3431 rajveer 552
    result.success = self._handler.getTickets(args.searchFilter)
3131 rajveer 553
    oprot.writeMessageBegin("getTickets", TMessageType.REPLY, seqid)
554
    result.write(oprot)
555
    oprot.writeMessageEnd()
556
    oprot.trans.flush()
557
 
3376 rajveer 558
  def process_getUnassignedTickets(self, seqid, iprot, oprot):
559
    args = getUnassignedTickets_args()
3131 rajveer 560
    args.read(iprot)
561
    iprot.readMessageEnd()
3376 rajveer 562
    result = getUnassignedTickets_result()
563
    result.success = self._handler.getUnassignedTickets()
564
    oprot.writeMessageBegin("getUnassignedTickets", TMessageType.REPLY, seqid)
3131 rajveer 565
    result.write(oprot)
566
    oprot.writeMessageEnd()
567
    oprot.trans.flush()
568
 
569
  def process_updateTicket(self, seqid, iprot, oprot):
570
    args = updateTicket_args()
571
    args.read(iprot)
572
    iprot.readMessageEnd()
573
    result = updateTicket_result()
3376 rajveer 574
    self._handler.updateTicket(args.ticket, args.activity)
3131 rajveer 575
    oprot.writeMessageBegin("updateTicket", TMessageType.REPLY, seqid)
576
    result.write(oprot)
577
    oprot.writeMessageEnd()
578
    oprot.trans.flush()
579
 
580
  def process_insertTicket(self, seqid, iprot, oprot):
581
    args = insertTicket_args()
582
    args.read(iprot)
583
    iprot.readMessageEnd()
584
    result = insertTicket_result()
3376 rajveer 585
    result.success = self._handler.insertTicket(args.ticket, args.activity)
3131 rajveer 586
    oprot.writeMessageBegin("insertTicket", TMessageType.REPLY, seqid)
587
    result.write(oprot)
588
    oprot.writeMessageEnd()
589
    oprot.trans.flush()
590
 
591
  def process_getActivities(self, seqid, iprot, oprot):
592
    args = getActivities_args()
593
    args.read(iprot)
594
    iprot.readMessageEnd()
595
    result = getActivities_result()
3431 rajveer 596
    result.success = self._handler.getActivities(args.searchFilter)
3131 rajveer 597
    oprot.writeMessageBegin("getActivities", TMessageType.REPLY, seqid)
598
    result.write(oprot)
599
    oprot.writeMessageEnd()
600
    oprot.trans.flush()
601
 
602
  def process_insertActivity(self, seqid, iprot, oprot):
603
    args = insertActivity_args()
604
    args.read(iprot)
605
    iprot.readMessageEnd()
606
    result = insertActivity_result()
3431 rajveer 607
    result.success = self._handler.insertActivity(args.activity)
3131 rajveer 608
    oprot.writeMessageBegin("insertActivity", TMessageType.REPLY, seqid)
609
    result.write(oprot)
610
    oprot.writeMessageEnd()
611
    oprot.trans.flush()
612
 
3431 rajveer 613
  def process_markAsRead(self, seqid, iprot, oprot):
614
    args = markAsRead_args()
3131 rajveer 615
    args.read(iprot)
616
    iprot.readMessageEnd()
3431 rajveer 617
    result = markAsRead_result()
618
    self._handler.markAsRead(args.activityId, args.agentId)
619
    oprot.writeMessageBegin("markAsRead", TMessageType.REPLY, seqid)
3131 rajveer 620
    result.write(oprot)
621
    oprot.writeMessageEnd()
622
    oprot.trans.flush()
623
 
3431 rajveer 624
  def process_getAgents(self, seqid, iprot, oprot):
625
    args = getAgents_args()
3131 rajveer 626
    args.read(iprot)
627
    iprot.readMessageEnd()
3431 rajveer 628
    result = getAgents_result()
629
    result.success = self._handler.getAgents(args.searchFilter)
630
    oprot.writeMessageBegin("getAgents", TMessageType.REPLY, seqid)
3131 rajveer 631
    result.write(oprot)
632
    oprot.writeMessageEnd()
633
    oprot.trans.flush()
634
 
635
  def process_updatePasswordForAgent(self, seqid, iprot, oprot):
636
    args = updatePasswordForAgent_args()
637
    args.read(iprot)
638
    iprot.readMessageEnd()
639
    result = updatePasswordForAgent_result()
640
    self._handler.updatePasswordForAgent(args.agentEmailId, args.password)
641
    oprot.writeMessageBegin("updatePasswordForAgent", TMessageType.REPLY, seqid)
642
    result.write(oprot)
643
    oprot.writeMessageEnd()
644
    oprot.trans.flush()
645
 
646
  def process_getRoleNamesForAgent(self, seqid, iprot, oprot):
647
    args = getRoleNamesForAgent_args()
648
    args.read(iprot)
649
    iprot.readMessageEnd()
650
    result = getRoleNamesForAgent_result()
651
    result.success = self._handler.getRoleNamesForAgent(args.agentEmailId)
652
    oprot.writeMessageBegin("getRoleNamesForAgent", TMessageType.REPLY, seqid)
653
    result.write(oprot)
654
    oprot.writeMessageEnd()
655
    oprot.trans.flush()
656
 
657
  def process_getPermissionsForRoleName(self, seqid, iprot, oprot):
658
    args = getPermissionsForRoleName_args()
659
    args.read(iprot)
660
    iprot.readMessageEnd()
661
    result = getPermissionsForRoleName_result()
662
    result.success = self._handler.getPermissionsForRoleName(args.roleName)
663
    oprot.writeMessageBegin("getPermissionsForRoleName", TMessageType.REPLY, seqid)
664
    result.write(oprot)
665
    oprot.writeMessageEnd()
666
    oprot.trans.flush()
667
 
3376 rajveer 668
  def process_getLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
669
    args = getLastEmailProcessedTimestamp_args()
670
    args.read(iprot)
671
    iprot.readMessageEnd()
672
    result = getLastEmailProcessedTimestamp_result()
673
    result.success = self._handler.getLastEmailProcessedTimestamp()
674
    oprot.writeMessageBegin("getLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
675
    result.write(oprot)
676
    oprot.writeMessageEnd()
677
    oprot.trans.flush()
3131 rajveer 678
 
3376 rajveer 679
  def process_updateLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
680
    args = updateLastEmailProcessedTimestamp_args()
681
    args.read(iprot)
682
    iprot.readMessageEnd()
683
    result = updateLastEmailProcessedTimestamp_result()
684
    self._handler.updateLastEmailProcessedTimestamp(args.timestamp)
685
    oprot.writeMessageBegin("updateLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
686
    result.write(oprot)
687
    oprot.writeMessageEnd()
688
    oprot.trans.flush()
689
 
3499 mandeep.dh 690
  def process_processCODTxn(self, seqid, iprot, oprot):
691
    args = processCODTxn_args()
692
    args.read(iprot)
693
    iprot.readMessageEnd()
694
    self._handler.processCODTxn(args.transactionId)
3530 mandeep.dh 695
    return
3376 rajveer 696
 
3499 mandeep.dh 697
 
3131 rajveer 698
# HELPER FUNCTIONS AND STRUCTURES
699
 
700
class getTickets_args:
701
  """
702
  Attributes:
3431 rajveer 703
   - searchFilter
3131 rajveer 704
  """
705
 
706
  thrift_spec = (
707
    None, # 0
3431 rajveer 708
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 709
  )
710
 
3431 rajveer 711
  def __init__(self, searchFilter=None,):
712
    self.searchFilter = searchFilter
3131 rajveer 713
 
714
  def read(self, iprot):
715
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
716
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
717
      return
718
    iprot.readStructBegin()
719
    while True:
720
      (fname, ftype, fid) = iprot.readFieldBegin()
721
      if ftype == TType.STOP:
722
        break
723
      if fid == 1:
3431 rajveer 724
        if ftype == TType.STRUCT:
725
          self.searchFilter = SearchFilter()
726
          self.searchFilter.read(iprot)
3131 rajveer 727
        else:
728
          iprot.skip(ftype)
729
      else:
730
        iprot.skip(ftype)
731
      iprot.readFieldEnd()
732
    iprot.readStructEnd()
733
 
734
  def write(self, oprot):
735
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
736
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
737
      return
738
    oprot.writeStructBegin('getTickets_args')
3431 rajveer 739
    if self.searchFilter is not None:
740
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
741
      self.searchFilter.write(oprot)
3131 rajveer 742
      oprot.writeFieldEnd()
743
    oprot.writeFieldStop()
744
    oprot.writeStructEnd()
745
 
3431 rajveer 746
  def validate(self):
747
    return
3131 rajveer 748
 
749
 
750
  def __repr__(self):
751
    L = ['%s=%r' % (key, value)
752
      for key, value in self.__dict__.iteritems()]
753
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
754
 
755
  def __eq__(self, other):
756
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
757
 
758
  def __ne__(self, other):
759
    return not (self == other)
760
 
3431 rajveer 761
class getTickets_result:
3131 rajveer 762
  """
763
  Attributes:
764
   - success
765
  """
766
 
767
  thrift_spec = (
768
    (0, TType.LIST, 'success', (TType.STRUCT,(Ticket, Ticket.thrift_spec)), None, ), # 0
769
  )
770
 
771
  def __init__(self, success=None,):
772
    self.success = success
773
 
774
  def read(self, iprot):
775
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
776
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
777
      return
778
    iprot.readStructBegin()
779
    while True:
780
      (fname, ftype, fid) = iprot.readFieldBegin()
781
      if ftype == TType.STOP:
782
        break
783
      if fid == 0:
784
        if ftype == TType.LIST:
785
          self.success = []
786
          (_etype17, _size14) = iprot.readListBegin()
787
          for _i18 in xrange(_size14):
788
            _elem19 = Ticket()
789
            _elem19.read(iprot)
790
            self.success.append(_elem19)
791
          iprot.readListEnd()
792
        else:
793
          iprot.skip(ftype)
794
      else:
795
        iprot.skip(ftype)
796
      iprot.readFieldEnd()
797
    iprot.readStructEnd()
798
 
799
  def write(self, oprot):
800
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
801
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
802
      return
3431 rajveer 803
    oprot.writeStructBegin('getTickets_result')
804
    if self.success is not None:
3131 rajveer 805
      oprot.writeFieldBegin('success', TType.LIST, 0)
806
      oprot.writeListBegin(TType.STRUCT, len(self.success))
807
      for iter20 in self.success:
808
        iter20.write(oprot)
809
      oprot.writeListEnd()
810
      oprot.writeFieldEnd()
811
    oprot.writeFieldStop()
812
    oprot.writeStructEnd()
813
 
3431 rajveer 814
  def validate(self):
815
    return
816
 
817
 
3131 rajveer 818
  def __repr__(self):
819
    L = ['%s=%r' % (key, value)
820
      for key, value in self.__dict__.iteritems()]
821
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
822
 
823
  def __eq__(self, other):
824
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
825
 
826
  def __ne__(self, other):
827
    return not (self == other)
828
 
3431 rajveer 829
class getUnassignedTickets_args:
3376 rajveer 830
 
831
  thrift_spec = (
832
  )
833
 
834
  def read(self, iprot):
835
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
836
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
837
      return
838
    iprot.readStructBegin()
839
    while True:
840
      (fname, ftype, fid) = iprot.readFieldBegin()
841
      if ftype == TType.STOP:
842
        break
843
      else:
844
        iprot.skip(ftype)
845
      iprot.readFieldEnd()
846
    iprot.readStructEnd()
847
 
848
  def write(self, oprot):
849
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
850
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
851
      return
3431 rajveer 852
    oprot.writeStructBegin('getUnassignedTickets_args')
3376 rajveer 853
    oprot.writeFieldStop()
854
    oprot.writeStructEnd()
855
 
3431 rajveer 856
  def validate(self):
857
    return
858
 
859
 
3376 rajveer 860
  def __repr__(self):
861
    L = ['%s=%r' % (key, value)
862
      for key, value in self.__dict__.iteritems()]
863
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
864
 
865
  def __eq__(self, other):
866
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
867
 
868
  def __ne__(self, other):
869
    return not (self == other)
870
 
3431 rajveer 871
class getUnassignedTickets_result:
3376 rajveer 872
  """
873
  Attributes:
874
   - success
875
  """
876
 
877
  thrift_spec = (
878
    (0, TType.LIST, 'success', (TType.STRUCT,(Ticket, Ticket.thrift_spec)), None, ), # 0
879
  )
880
 
881
  def __init__(self, success=None,):
882
    self.success = success
883
 
884
  def read(self, iprot):
885
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
886
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
887
      return
888
    iprot.readStructBegin()
889
    while True:
890
      (fname, ftype, fid) = iprot.readFieldBegin()
891
      if ftype == TType.STOP:
892
        break
893
      if fid == 0:
894
        if ftype == TType.LIST:
895
          self.success = []
896
          (_etype24, _size21) = iprot.readListBegin()
897
          for _i25 in xrange(_size21):
898
            _elem26 = Ticket()
899
            _elem26.read(iprot)
900
            self.success.append(_elem26)
901
          iprot.readListEnd()
902
        else:
903
          iprot.skip(ftype)
904
      else:
905
        iprot.skip(ftype)
906
      iprot.readFieldEnd()
907
    iprot.readStructEnd()
908
 
909
  def write(self, oprot):
910
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
911
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
912
      return
3431 rajveer 913
    oprot.writeStructBegin('getUnassignedTickets_result')
914
    if self.success is not None:
3376 rajveer 915
      oprot.writeFieldBegin('success', TType.LIST, 0)
916
      oprot.writeListBegin(TType.STRUCT, len(self.success))
917
      for iter27 in self.success:
918
        iter27.write(oprot)
919
      oprot.writeListEnd()
920
      oprot.writeFieldEnd()
921
    oprot.writeFieldStop()
922
    oprot.writeStructEnd()
923
 
3431 rajveer 924
  def validate(self):
925
    return
3376 rajveer 926
 
927
 
3131 rajveer 928
  def __repr__(self):
929
    L = ['%s=%r' % (key, value)
930
      for key, value in self.__dict__.iteritems()]
931
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
932
 
933
  def __eq__(self, other):
934
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
935
 
936
  def __ne__(self, other):
937
    return not (self == other)
938
 
939
class updateTicket_args:
940
  """
941
  Attributes:
942
   - ticket
3376 rajveer 943
   - activity
3131 rajveer 944
  """
945
 
946
  thrift_spec = (
947
    None, # 0
948
    (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
3376 rajveer 949
    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
3131 rajveer 950
  )
951
 
3376 rajveer 952
  def __init__(self, ticket=None, activity=None,):
3131 rajveer 953
    self.ticket = ticket
3376 rajveer 954
    self.activity = activity
3131 rajveer 955
 
956
  def read(self, iprot):
957
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
958
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
959
      return
960
    iprot.readStructBegin()
961
    while True:
962
      (fname, ftype, fid) = iprot.readFieldBegin()
963
      if ftype == TType.STOP:
964
        break
965
      if fid == 1:
966
        if ftype == TType.STRUCT:
967
          self.ticket = Ticket()
968
          self.ticket.read(iprot)
969
        else:
970
          iprot.skip(ftype)
3376 rajveer 971
      elif fid == 2:
972
        if ftype == TType.STRUCT:
973
          self.activity = Activity()
974
          self.activity.read(iprot)
975
        else:
976
          iprot.skip(ftype)
3131 rajveer 977
      else:
978
        iprot.skip(ftype)
979
      iprot.readFieldEnd()
980
    iprot.readStructEnd()
981
 
982
  def write(self, oprot):
983
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
984
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
985
      return
986
    oprot.writeStructBegin('updateTicket_args')
3431 rajveer 987
    if self.ticket is not None:
3131 rajveer 988
      oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
989
      self.ticket.write(oprot)
990
      oprot.writeFieldEnd()
3431 rajveer 991
    if self.activity is not None:
3376 rajveer 992
      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
993
      self.activity.write(oprot)
994
      oprot.writeFieldEnd()
3131 rajveer 995
    oprot.writeFieldStop()
996
    oprot.writeStructEnd()
997
 
3431 rajveer 998
  def validate(self):
999
    return
1000
 
1001
 
3131 rajveer 1002
  def __repr__(self):
1003
    L = ['%s=%r' % (key, value)
1004
      for key, value in self.__dict__.iteritems()]
1005
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1006
 
1007
  def __eq__(self, other):
1008
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1009
 
1010
  def __ne__(self, other):
1011
    return not (self == other)
1012
 
1013
class updateTicket_result:
1014
 
1015
  thrift_spec = (
1016
  )
1017
 
1018
  def read(self, iprot):
1019
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1020
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1021
      return
1022
    iprot.readStructBegin()
1023
    while True:
1024
      (fname, ftype, fid) = iprot.readFieldBegin()
1025
      if ftype == TType.STOP:
1026
        break
1027
      else:
1028
        iprot.skip(ftype)
1029
      iprot.readFieldEnd()
1030
    iprot.readStructEnd()
1031
 
1032
  def write(self, oprot):
1033
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1034
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1035
      return
1036
    oprot.writeStructBegin('updateTicket_result')
1037
    oprot.writeFieldStop()
1038
    oprot.writeStructEnd()
1039
 
3431 rajveer 1040
  def validate(self):
1041
    return
1042
 
1043
 
3131 rajveer 1044
  def __repr__(self):
1045
    L = ['%s=%r' % (key, value)
1046
      for key, value in self.__dict__.iteritems()]
1047
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1048
 
1049
  def __eq__(self, other):
1050
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1051
 
1052
  def __ne__(self, other):
1053
    return not (self == other)
1054
 
1055
class insertTicket_args:
1056
  """
1057
  Attributes:
1058
   - ticket
3376 rajveer 1059
   - activity
3131 rajveer 1060
  """
1061
 
1062
  thrift_spec = (
1063
    None, # 0
1064
    (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
3376 rajveer 1065
    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
3131 rajveer 1066
  )
1067
 
3376 rajveer 1068
  def __init__(self, ticket=None, activity=None,):
3131 rajveer 1069
    self.ticket = ticket
3376 rajveer 1070
    self.activity = activity
3131 rajveer 1071
 
1072
  def read(self, iprot):
1073
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1074
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1075
      return
1076
    iprot.readStructBegin()
1077
    while True:
1078
      (fname, ftype, fid) = iprot.readFieldBegin()
1079
      if ftype == TType.STOP:
1080
        break
1081
      if fid == 1:
1082
        if ftype == TType.STRUCT:
1083
          self.ticket = Ticket()
1084
          self.ticket.read(iprot)
1085
        else:
1086
          iprot.skip(ftype)
3376 rajveer 1087
      elif fid == 2:
1088
        if ftype == TType.STRUCT:
1089
          self.activity = Activity()
1090
          self.activity.read(iprot)
1091
        else:
1092
          iprot.skip(ftype)
3131 rajveer 1093
      else:
1094
        iprot.skip(ftype)
1095
      iprot.readFieldEnd()
1096
    iprot.readStructEnd()
1097
 
1098
  def write(self, oprot):
1099
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1100
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1101
      return
1102
    oprot.writeStructBegin('insertTicket_args')
3431 rajveer 1103
    if self.ticket is not None:
3131 rajveer 1104
      oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
1105
      self.ticket.write(oprot)
1106
      oprot.writeFieldEnd()
3431 rajveer 1107
    if self.activity is not None:
3376 rajveer 1108
      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
1109
      self.activity.write(oprot)
1110
      oprot.writeFieldEnd()
3131 rajveer 1111
    oprot.writeFieldStop()
1112
    oprot.writeStructEnd()
1113
 
3431 rajveer 1114
  def validate(self):
1115
    return
1116
 
1117
 
3131 rajveer 1118
  def __repr__(self):
1119
    L = ['%s=%r' % (key, value)
1120
      for key, value in self.__dict__.iteritems()]
1121
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1122
 
1123
  def __eq__(self, other):
1124
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1125
 
1126
  def __ne__(self, other):
1127
    return not (self == other)
1128
 
1129
class insertTicket_result:
1130
  """
1131
  Attributes:
1132
   - success
1133
  """
1134
 
1135
  thrift_spec = (
1136
    (0, TType.I64, 'success', None, None, ), # 0
1137
  )
1138
 
1139
  def __init__(self, success=None,):
1140
    self.success = success
1141
 
1142
  def read(self, iprot):
1143
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1144
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1145
      return
1146
    iprot.readStructBegin()
1147
    while True:
1148
      (fname, ftype, fid) = iprot.readFieldBegin()
1149
      if ftype == TType.STOP:
1150
        break
1151
      if fid == 0:
1152
        if ftype == TType.I64:
1153
          self.success = iprot.readI64();
1154
        else:
1155
          iprot.skip(ftype)
1156
      else:
1157
        iprot.skip(ftype)
1158
      iprot.readFieldEnd()
1159
    iprot.readStructEnd()
1160
 
1161
  def write(self, oprot):
1162
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1163
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1164
      return
1165
    oprot.writeStructBegin('insertTicket_result')
3431 rajveer 1166
    if self.success is not None:
3131 rajveer 1167
      oprot.writeFieldBegin('success', TType.I64, 0)
1168
      oprot.writeI64(self.success)
1169
      oprot.writeFieldEnd()
1170
    oprot.writeFieldStop()
1171
    oprot.writeStructEnd()
1172
 
3431 rajveer 1173
  def validate(self):
1174
    return
1175
 
1176
 
3131 rajveer 1177
  def __repr__(self):
1178
    L = ['%s=%r' % (key, value)
1179
      for key, value in self.__dict__.iteritems()]
1180
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1181
 
1182
  def __eq__(self, other):
1183
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1184
 
1185
  def __ne__(self, other):
1186
    return not (self == other)
1187
 
1188
class getActivities_args:
1189
  """
1190
  Attributes:
3431 rajveer 1191
   - searchFilter
3131 rajveer 1192
  """
1193
 
1194
  thrift_spec = (
1195
    None, # 0
3431 rajveer 1196
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 1197
  )
1198
 
3431 rajveer 1199
  def __init__(self, searchFilter=None,):
1200
    self.searchFilter = searchFilter
3131 rajveer 1201
 
1202
  def read(self, iprot):
1203
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1204
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1205
      return
1206
    iprot.readStructBegin()
1207
    while True:
1208
      (fname, ftype, fid) = iprot.readFieldBegin()
1209
      if ftype == TType.STOP:
1210
        break
1211
      if fid == 1:
3431 rajveer 1212
        if ftype == TType.STRUCT:
1213
          self.searchFilter = SearchFilter()
1214
          self.searchFilter.read(iprot)
3131 rajveer 1215
        else:
1216
          iprot.skip(ftype)
1217
      else:
1218
        iprot.skip(ftype)
1219
      iprot.readFieldEnd()
1220
    iprot.readStructEnd()
1221
 
1222
  def write(self, oprot):
1223
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1224
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1225
      return
1226
    oprot.writeStructBegin('getActivities_args')
3431 rajveer 1227
    if self.searchFilter is not None:
1228
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
1229
      self.searchFilter.write(oprot)
3131 rajveer 1230
      oprot.writeFieldEnd()
1231
    oprot.writeFieldStop()
1232
    oprot.writeStructEnd()
1233
 
3431 rajveer 1234
  def validate(self):
1235
    return
1236
 
1237
 
3131 rajveer 1238
  def __repr__(self):
1239
    L = ['%s=%r' % (key, value)
1240
      for key, value in self.__dict__.iteritems()]
1241
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1242
 
1243
  def __eq__(self, other):
1244
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1245
 
1246
  def __ne__(self, other):
1247
    return not (self == other)
1248
 
1249
class getActivities_result:
1250
  """
1251
  Attributes:
1252
   - success
1253
  """
1254
 
1255
  thrift_spec = (
1256
    (0, TType.LIST, 'success', (TType.STRUCT,(Activity, Activity.thrift_spec)), None, ), # 0
1257
  )
1258
 
1259
  def __init__(self, success=None,):
1260
    self.success = success
1261
 
1262
  def read(self, iprot):
1263
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1264
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1265
      return
1266
    iprot.readStructBegin()
1267
    while True:
1268
      (fname, ftype, fid) = iprot.readFieldBegin()
1269
      if ftype == TType.STOP:
1270
        break
1271
      if fid == 0:
1272
        if ftype == TType.LIST:
1273
          self.success = []
3376 rajveer 1274
          (_etype31, _size28) = iprot.readListBegin()
1275
          for _i32 in xrange(_size28):
1276
            _elem33 = Activity()
1277
            _elem33.read(iprot)
1278
            self.success.append(_elem33)
3131 rajveer 1279
          iprot.readListEnd()
1280
        else:
1281
          iprot.skip(ftype)
1282
      else:
1283
        iprot.skip(ftype)
1284
      iprot.readFieldEnd()
1285
    iprot.readStructEnd()
1286
 
1287
  def write(self, oprot):
1288
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1289
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1290
      return
1291
    oprot.writeStructBegin('getActivities_result')
3431 rajveer 1292
    if self.success is not None:
3131 rajveer 1293
      oprot.writeFieldBegin('success', TType.LIST, 0)
1294
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3376 rajveer 1295
      for iter34 in self.success:
1296
        iter34.write(oprot)
3131 rajveer 1297
      oprot.writeListEnd()
1298
      oprot.writeFieldEnd()
1299
    oprot.writeFieldStop()
1300
    oprot.writeStructEnd()
1301
 
3431 rajveer 1302
  def validate(self):
1303
    return
1304
 
1305
 
3131 rajveer 1306
  def __repr__(self):
1307
    L = ['%s=%r' % (key, value)
1308
      for key, value in self.__dict__.iteritems()]
1309
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1310
 
1311
  def __eq__(self, other):
1312
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1313
 
1314
  def __ne__(self, other):
1315
    return not (self == other)
1316
 
3431 rajveer 1317
class insertActivity_args:
3376 rajveer 1318
  """
1319
  Attributes:
3431 rajveer 1320
   - activity
3376 rajveer 1321
  """
1322
 
1323
  thrift_spec = (
1324
    None, # 0
3431 rajveer 1325
    (1, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 1
3376 rajveer 1326
  )
1327
 
3431 rajveer 1328
  def __init__(self, activity=None,):
1329
    self.activity = activity
3376 rajveer 1330
 
1331
  def read(self, iprot):
1332
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1333
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1334
      return
1335
    iprot.readStructBegin()
1336
    while True:
1337
      (fname, ftype, fid) = iprot.readFieldBegin()
1338
      if ftype == TType.STOP:
1339
        break
1340
      if fid == 1:
3431 rajveer 1341
        if ftype == TType.STRUCT:
1342
          self.activity = Activity()
1343
          self.activity.read(iprot)
3376 rajveer 1344
        else:
1345
          iprot.skip(ftype)
1346
      else:
1347
        iprot.skip(ftype)
1348
      iprot.readFieldEnd()
1349
    iprot.readStructEnd()
1350
 
1351
  def write(self, oprot):
1352
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1353
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1354
      return
3431 rajveer 1355
    oprot.writeStructBegin('insertActivity_args')
1356
    if self.activity is not None:
1357
      oprot.writeFieldBegin('activity', TType.STRUCT, 1)
1358
      self.activity.write(oprot)
3376 rajveer 1359
      oprot.writeFieldEnd()
1360
    oprot.writeFieldStop()
1361
    oprot.writeStructEnd()
1362
 
3431 rajveer 1363
  def validate(self):
1364
    return
1365
 
1366
 
3376 rajveer 1367
  def __repr__(self):
1368
    L = ['%s=%r' % (key, value)
1369
      for key, value in self.__dict__.iteritems()]
1370
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1371
 
1372
  def __eq__(self, other):
1373
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1374
 
1375
  def __ne__(self, other):
1376
    return not (self == other)
1377
 
3431 rajveer 1378
class insertActivity_result:
3376 rajveer 1379
  """
1380
  Attributes:
1381
   - success
1382
  """
1383
 
1384
  thrift_spec = (
3431 rajveer 1385
    (0, TType.I64, 'success', None, None, ), # 0
3376 rajveer 1386
  )
1387
 
1388
  def __init__(self, success=None,):
1389
    self.success = success
1390
 
1391
  def read(self, iprot):
1392
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1393
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1394
      return
1395
    iprot.readStructBegin()
1396
    while True:
1397
      (fname, ftype, fid) = iprot.readFieldBegin()
1398
      if ftype == TType.STOP:
1399
        break
1400
      if fid == 0:
3131 rajveer 1401
        if ftype == TType.I64:
3431 rajveer 1402
          self.success = iprot.readI64();
3131 rajveer 1403
        else:
1404
          iprot.skip(ftype)
1405
      else:
1406
        iprot.skip(ftype)
1407
      iprot.readFieldEnd()
1408
    iprot.readStructEnd()
1409
 
1410
  def write(self, oprot):
1411
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1412
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1413
      return
3431 rajveer 1414
    oprot.writeStructBegin('insertActivity_result')
1415
    if self.success is not None:
1416
      oprot.writeFieldBegin('success', TType.I64, 0)
1417
      oprot.writeI64(self.success)
3131 rajveer 1418
      oprot.writeFieldEnd()
1419
    oprot.writeFieldStop()
1420
    oprot.writeStructEnd()
1421
 
3431 rajveer 1422
  def validate(self):
1423
    return
3131 rajveer 1424
 
1425
 
1426
  def __repr__(self):
1427
    L = ['%s=%r' % (key, value)
1428
      for key, value in self.__dict__.iteritems()]
1429
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1430
 
1431
  def __eq__(self, other):
1432
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1433
 
1434
  def __ne__(self, other):
1435
    return not (self == other)
1436
 
3431 rajveer 1437
class markAsRead_args:
3131 rajveer 1438
  """
1439
  Attributes:
1440
   - activityId
3431 rajveer 1441
   - agentId
3131 rajveer 1442
  """
1443
 
1444
  thrift_spec = (
1445
    None, # 0
1446
    (1, TType.I64, 'activityId', None, None, ), # 1
3431 rajveer 1447
    (2, TType.I64, 'agentId', None, None, ), # 2
3131 rajveer 1448
  )
1449
 
3431 rajveer 1450
  def __init__(self, activityId=None, agentId=None,):
3131 rajveer 1451
    self.activityId = activityId
3431 rajveer 1452
    self.agentId = agentId
3131 rajveer 1453
 
1454
  def read(self, iprot):
1455
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1456
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1457
      return
1458
    iprot.readStructBegin()
1459
    while True:
1460
      (fname, ftype, fid) = iprot.readFieldBegin()
1461
      if ftype == TType.STOP:
1462
        break
1463
      if fid == 1:
1464
        if ftype == TType.I64:
1465
          self.activityId = iprot.readI64();
1466
        else:
1467
          iprot.skip(ftype)
3431 rajveer 1468
      elif fid == 2:
1469
        if ftype == TType.I64:
1470
          self.agentId = iprot.readI64();
1471
        else:
1472
          iprot.skip(ftype)
3131 rajveer 1473
      else:
1474
        iprot.skip(ftype)
1475
      iprot.readFieldEnd()
1476
    iprot.readStructEnd()
1477
 
1478
  def write(self, oprot):
1479
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1480
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1481
      return
3431 rajveer 1482
    oprot.writeStructBegin('markAsRead_args')
1483
    if self.activityId is not None:
3131 rajveer 1484
      oprot.writeFieldBegin('activityId', TType.I64, 1)
1485
      oprot.writeI64(self.activityId)
1486
      oprot.writeFieldEnd()
3431 rajveer 1487
    if self.agentId is not None:
1488
      oprot.writeFieldBegin('agentId', TType.I64, 2)
1489
      oprot.writeI64(self.agentId)
1490
      oprot.writeFieldEnd()
3131 rajveer 1491
    oprot.writeFieldStop()
1492
    oprot.writeStructEnd()
1493
 
3431 rajveer 1494
  def validate(self):
1495
    return
3131 rajveer 1496
 
1497
 
1498
  def __repr__(self):
1499
    L = ['%s=%r' % (key, value)
1500
      for key, value in self.__dict__.iteritems()]
1501
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1502
 
1503
  def __eq__(self, other):
1504
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1505
 
1506
  def __ne__(self, other):
1507
    return not (self == other)
1508
 
3431 rajveer 1509
class markAsRead_result:
3131 rajveer 1510
 
1511
  thrift_spec = (
1512
  )
1513
 
1514
  def read(self, iprot):
1515
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1516
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1517
      return
1518
    iprot.readStructBegin()
1519
    while True:
1520
      (fname, ftype, fid) = iprot.readFieldBegin()
1521
      if ftype == TType.STOP:
1522
        break
1523
      else:
1524
        iprot.skip(ftype)
1525
      iprot.readFieldEnd()
1526
    iprot.readStructEnd()
1527
 
1528
  def write(self, oprot):
1529
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1530
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1531
      return
3431 rajveer 1532
    oprot.writeStructBegin('markAsRead_result')
3131 rajveer 1533
    oprot.writeFieldStop()
1534
    oprot.writeStructEnd()
1535
 
3431 rajveer 1536
  def validate(self):
1537
    return
3131 rajveer 1538
 
1539
 
1540
  def __repr__(self):
1541
    L = ['%s=%r' % (key, value)
1542
      for key, value in self.__dict__.iteritems()]
1543
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1544
 
1545
  def __eq__(self, other):
1546
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1547
 
1548
  def __ne__(self, other):
1549
    return not (self == other)
1550
 
3431 rajveer 1551
class getAgents_args:
3131 rajveer 1552
  """
1553
  Attributes:
3431 rajveer 1554
   - searchFilter
3131 rajveer 1555
  """
1556
 
1557
  thrift_spec = (
1558
    None, # 0
3431 rajveer 1559
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 1560
  )
1561
 
3431 rajveer 1562
  def __init__(self, searchFilter=None,):
1563
    self.searchFilter = searchFilter
3131 rajveer 1564
 
1565
  def read(self, iprot):
1566
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1567
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1568
      return
1569
    iprot.readStructBegin()
1570
    while True:
1571
      (fname, ftype, fid) = iprot.readFieldBegin()
1572
      if ftype == TType.STOP:
1573
        break
1574
      if fid == 1:
1575
        if ftype == TType.STRUCT:
3431 rajveer 1576
          self.searchFilter = SearchFilter()
1577
          self.searchFilter.read(iprot)
3131 rajveer 1578
        else:
1579
          iprot.skip(ftype)
1580
      else:
1581
        iprot.skip(ftype)
1582
      iprot.readFieldEnd()
1583
    iprot.readStructEnd()
1584
 
1585
  def write(self, oprot):
1586
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1587
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1588
      return
3431 rajveer 1589
    oprot.writeStructBegin('getAgents_args')
1590
    if self.searchFilter is not None:
1591
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
1592
      self.searchFilter.write(oprot)
3131 rajveer 1593
      oprot.writeFieldEnd()
1594
    oprot.writeFieldStop()
1595
    oprot.writeStructEnd()
1596
 
3431 rajveer 1597
  def validate(self):
1598
    return
3131 rajveer 1599
 
1600
 
1601
  def __repr__(self):
1602
    L = ['%s=%r' % (key, value)
1603
      for key, value in self.__dict__.iteritems()]
1604
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1605
 
1606
  def __eq__(self, other):
1607
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1608
 
1609
  def __ne__(self, other):
1610
    return not (self == other)
1611
 
3431 rajveer 1612
class getAgents_result:
3131 rajveer 1613
  """
1614
  Attributes:
1615
   - success
1616
  """
1617
 
1618
  thrift_spec = (
1619
    (0, TType.LIST, 'success', (TType.STRUCT,(Agent, Agent.thrift_spec)), None, ), # 0
1620
  )
1621
 
1622
  def __init__(self, success=None,):
1623
    self.success = success
1624
 
1625
  def read(self, iprot):
1626
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1627
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1628
      return
1629
    iprot.readStructBegin()
1630
    while True:
1631
      (fname, ftype, fid) = iprot.readFieldBegin()
1632
      if ftype == TType.STOP:
1633
        break
1634
      if fid == 0:
1635
        if ftype == TType.LIST:
1636
          self.success = []
3431 rajveer 1637
          (_etype38, _size35) = iprot.readListBegin()
1638
          for _i39 in xrange(_size35):
1639
            _elem40 = Agent()
1640
            _elem40.read(iprot)
1641
            self.success.append(_elem40)
3131 rajveer 1642
          iprot.readListEnd()
1643
        else:
1644
          iprot.skip(ftype)
1645
      else:
1646
        iprot.skip(ftype)
1647
      iprot.readFieldEnd()
1648
    iprot.readStructEnd()
1649
 
1650
  def write(self, oprot):
1651
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1652
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1653
      return
3431 rajveer 1654
    oprot.writeStructBegin('getAgents_result')
1655
    if self.success is not None:
3131 rajveer 1656
      oprot.writeFieldBegin('success', TType.LIST, 0)
1657
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3431 rajveer 1658
      for iter41 in self.success:
1659
        iter41.write(oprot)
3131 rajveer 1660
      oprot.writeListEnd()
1661
      oprot.writeFieldEnd()
1662
    oprot.writeFieldStop()
1663
    oprot.writeStructEnd()
1664
 
3431 rajveer 1665
  def validate(self):
1666
    return
3131 rajveer 1667
 
1668
 
1669
  def __repr__(self):
1670
    L = ['%s=%r' % (key, value)
1671
      for key, value in self.__dict__.iteritems()]
1672
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1673
 
1674
  def __eq__(self, other):
1675
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1676
 
1677
  def __ne__(self, other):
1678
    return not (self == other)
1679
 
1680
class updatePasswordForAgent_args:
1681
  """
1682
  Attributes:
1683
   - agentEmailId
1684
   - password
1685
  """
1686
 
1687
  thrift_spec = (
1688
    None, # 0
1689
    (1, TType.STRING, 'agentEmailId', None, None, ), # 1
1690
    (2, TType.STRING, 'password', None, None, ), # 2
1691
  )
1692
 
1693
  def __init__(self, agentEmailId=None, password=None,):
1694
    self.agentEmailId = agentEmailId
1695
    self.password = password
1696
 
1697
  def read(self, iprot):
1698
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1699
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1700
      return
1701
    iprot.readStructBegin()
1702
    while True:
1703
      (fname, ftype, fid) = iprot.readFieldBegin()
1704
      if ftype == TType.STOP:
1705
        break
1706
      if fid == 1:
1707
        if ftype == TType.STRING:
1708
          self.agentEmailId = iprot.readString();
1709
        else:
1710
          iprot.skip(ftype)
1711
      elif fid == 2:
1712
        if ftype == TType.STRING:
1713
          self.password = iprot.readString();
1714
        else:
1715
          iprot.skip(ftype)
1716
      else:
1717
        iprot.skip(ftype)
1718
      iprot.readFieldEnd()
1719
    iprot.readStructEnd()
1720
 
1721
  def write(self, oprot):
1722
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1723
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1724
      return
1725
    oprot.writeStructBegin('updatePasswordForAgent_args')
3431 rajveer 1726
    if self.agentEmailId is not None:
3131 rajveer 1727
      oprot.writeFieldBegin('agentEmailId', TType.STRING, 1)
1728
      oprot.writeString(self.agentEmailId)
1729
      oprot.writeFieldEnd()
3431 rajveer 1730
    if self.password is not None:
3131 rajveer 1731
      oprot.writeFieldBegin('password', TType.STRING, 2)
1732
      oprot.writeString(self.password)
1733
      oprot.writeFieldEnd()
1734
    oprot.writeFieldStop()
1735
    oprot.writeStructEnd()
1736
 
3431 rajveer 1737
  def validate(self):
1738
    return
1739
 
1740
 
3131 rajveer 1741
  def __repr__(self):
1742
    L = ['%s=%r' % (key, value)
1743
      for key, value in self.__dict__.iteritems()]
1744
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1745
 
1746
  def __eq__(self, other):
1747
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1748
 
1749
  def __ne__(self, other):
1750
    return not (self == other)
1751
 
1752
class updatePasswordForAgent_result:
1753
 
1754
  thrift_spec = (
1755
  )
1756
 
1757
  def read(self, iprot):
1758
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1759
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1760
      return
1761
    iprot.readStructBegin()
1762
    while True:
1763
      (fname, ftype, fid) = iprot.readFieldBegin()
1764
      if ftype == TType.STOP:
1765
        break
1766
      else:
1767
        iprot.skip(ftype)
1768
      iprot.readFieldEnd()
1769
    iprot.readStructEnd()
1770
 
1771
  def write(self, oprot):
1772
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1773
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1774
      return
1775
    oprot.writeStructBegin('updatePasswordForAgent_result')
1776
    oprot.writeFieldStop()
1777
    oprot.writeStructEnd()
1778
 
3431 rajveer 1779
  def validate(self):
1780
    return
1781
 
1782
 
3131 rajveer 1783
  def __repr__(self):
1784
    L = ['%s=%r' % (key, value)
1785
      for key, value in self.__dict__.iteritems()]
1786
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1787
 
1788
  def __eq__(self, other):
1789
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1790
 
1791
  def __ne__(self, other):
1792
    return not (self == other)
1793
 
1794
class getRoleNamesForAgent_args:
1795
  """
1796
  Attributes:
1797
   - agentEmailId
1798
  """
1799
 
1800
  thrift_spec = (
1801
    None, # 0
1802
    (1, TType.STRING, 'agentEmailId', None, None, ), # 1
1803
  )
1804
 
1805
  def __init__(self, agentEmailId=None,):
1806
    self.agentEmailId = agentEmailId
1807
 
1808
  def read(self, iprot):
1809
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1810
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1811
      return
1812
    iprot.readStructBegin()
1813
    while True:
1814
      (fname, ftype, fid) = iprot.readFieldBegin()
1815
      if ftype == TType.STOP:
1816
        break
1817
      if fid == 1:
1818
        if ftype == TType.STRING:
1819
          self.agentEmailId = iprot.readString();
1820
        else:
1821
          iprot.skip(ftype)
1822
      else:
1823
        iprot.skip(ftype)
1824
      iprot.readFieldEnd()
1825
    iprot.readStructEnd()
1826
 
1827
  def write(self, oprot):
1828
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1829
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1830
      return
1831
    oprot.writeStructBegin('getRoleNamesForAgent_args')
3431 rajveer 1832
    if self.agentEmailId is not None:
3131 rajveer 1833
      oprot.writeFieldBegin('agentEmailId', TType.STRING, 1)
1834
      oprot.writeString(self.agentEmailId)
1835
      oprot.writeFieldEnd()
1836
    oprot.writeFieldStop()
1837
    oprot.writeStructEnd()
1838
 
3431 rajveer 1839
  def validate(self):
1840
    return
1841
 
1842
 
3131 rajveer 1843
  def __repr__(self):
1844
    L = ['%s=%r' % (key, value)
1845
      for key, value in self.__dict__.iteritems()]
1846
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1847
 
1848
  def __eq__(self, other):
1849
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1850
 
1851
  def __ne__(self, other):
1852
    return not (self == other)
1853
 
1854
class getRoleNamesForAgent_result:
1855
  """
1856
  Attributes:
1857
   - success
1858
  """
1859
 
1860
  thrift_spec = (
1861
    (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
1862
  )
1863
 
1864
  def __init__(self, success=None,):
1865
    self.success = success
1866
 
1867
  def read(self, iprot):
1868
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1869
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1870
      return
1871
    iprot.readStructBegin()
1872
    while True:
1873
      (fname, ftype, fid) = iprot.readFieldBegin()
1874
      if ftype == TType.STOP:
1875
        break
1876
      if fid == 0:
1877
        if ftype == TType.LIST:
1878
          self.success = []
3431 rajveer 1879
          (_etype45, _size42) = iprot.readListBegin()
1880
          for _i46 in xrange(_size42):
1881
            _elem47 = iprot.readString();
1882
            self.success.append(_elem47)
3131 rajveer 1883
          iprot.readListEnd()
1884
        else:
1885
          iprot.skip(ftype)
1886
      else:
1887
        iprot.skip(ftype)
1888
      iprot.readFieldEnd()
1889
    iprot.readStructEnd()
1890
 
1891
  def write(self, oprot):
1892
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1893
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1894
      return
1895
    oprot.writeStructBegin('getRoleNamesForAgent_result')
3431 rajveer 1896
    if self.success is not None:
3131 rajveer 1897
      oprot.writeFieldBegin('success', TType.LIST, 0)
1898
      oprot.writeListBegin(TType.STRING, len(self.success))
3431 rajveer 1899
      for iter48 in self.success:
1900
        oprot.writeString(iter48)
3131 rajveer 1901
      oprot.writeListEnd()
1902
      oprot.writeFieldEnd()
1903
    oprot.writeFieldStop()
1904
    oprot.writeStructEnd()
1905
 
3431 rajveer 1906
  def validate(self):
1907
    return
1908
 
1909
 
3131 rajveer 1910
  def __repr__(self):
1911
    L = ['%s=%r' % (key, value)
1912
      for key, value in self.__dict__.iteritems()]
1913
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1914
 
1915
  def __eq__(self, other):
1916
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1917
 
1918
  def __ne__(self, other):
1919
    return not (self == other)
1920
 
1921
class getPermissionsForRoleName_args:
1922
  """
1923
  Attributes:
1924
   - roleName
1925
  """
1926
 
1927
  thrift_spec = (
1928
    None, # 0
1929
    (1, TType.STRING, 'roleName', None, None, ), # 1
1930
  )
1931
 
1932
  def __init__(self, roleName=None,):
1933
    self.roleName = roleName
1934
 
1935
  def read(self, iprot):
1936
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1937
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1938
      return
1939
    iprot.readStructBegin()
1940
    while True:
1941
      (fname, ftype, fid) = iprot.readFieldBegin()
1942
      if ftype == TType.STOP:
1943
        break
1944
      if fid == 1:
1945
        if ftype == TType.STRING:
1946
          self.roleName = iprot.readString();
1947
        else:
1948
          iprot.skip(ftype)
1949
      else:
1950
        iprot.skip(ftype)
1951
      iprot.readFieldEnd()
1952
    iprot.readStructEnd()
1953
 
1954
  def write(self, oprot):
1955
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1956
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1957
      return
1958
    oprot.writeStructBegin('getPermissionsForRoleName_args')
3431 rajveer 1959
    if self.roleName is not None:
3131 rajveer 1960
      oprot.writeFieldBegin('roleName', TType.STRING, 1)
1961
      oprot.writeString(self.roleName)
1962
      oprot.writeFieldEnd()
1963
    oprot.writeFieldStop()
1964
    oprot.writeStructEnd()
1965
 
3431 rajveer 1966
  def validate(self):
1967
    return
1968
 
1969
 
3131 rajveer 1970
  def __repr__(self):
1971
    L = ['%s=%r' % (key, value)
1972
      for key, value in self.__dict__.iteritems()]
1973
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1974
 
1975
  def __eq__(self, other):
1976
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1977
 
1978
  def __ne__(self, other):
1979
    return not (self == other)
1980
 
1981
class getPermissionsForRoleName_result:
1982
  """
1983
  Attributes:
1984
   - success
1985
  """
1986
 
1987
  thrift_spec = (
1988
    (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
1989
  )
1990
 
1991
  def __init__(self, success=None,):
1992
    self.success = success
1993
 
1994
  def read(self, iprot):
1995
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1996
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1997
      return
1998
    iprot.readStructBegin()
1999
    while True:
2000
      (fname, ftype, fid) = iprot.readFieldBegin()
2001
      if ftype == TType.STOP:
2002
        break
2003
      if fid == 0:
2004
        if ftype == TType.LIST:
2005
          self.success = []
3431 rajveer 2006
          (_etype52, _size49) = iprot.readListBegin()
2007
          for _i53 in xrange(_size49):
2008
            _elem54 = iprot.readString();
2009
            self.success.append(_elem54)
3131 rajveer 2010
          iprot.readListEnd()
2011
        else:
2012
          iprot.skip(ftype)
2013
      else:
2014
        iprot.skip(ftype)
2015
      iprot.readFieldEnd()
2016
    iprot.readStructEnd()
2017
 
2018
  def write(self, oprot):
2019
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2020
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2021
      return
2022
    oprot.writeStructBegin('getPermissionsForRoleName_result')
3431 rajveer 2023
    if self.success is not None:
3131 rajveer 2024
      oprot.writeFieldBegin('success', TType.LIST, 0)
2025
      oprot.writeListBegin(TType.STRING, len(self.success))
3431 rajveer 2026
      for iter55 in self.success:
2027
        oprot.writeString(iter55)
3131 rajveer 2028
      oprot.writeListEnd()
2029
      oprot.writeFieldEnd()
2030
    oprot.writeFieldStop()
2031
    oprot.writeStructEnd()
2032
 
3431 rajveer 2033
  def validate(self):
2034
    return
2035
 
2036
 
3131 rajveer 2037
  def __repr__(self):
2038
    L = ['%s=%r' % (key, value)
2039
      for key, value in self.__dict__.iteritems()]
2040
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2041
 
2042
  def __eq__(self, other):
2043
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2044
 
2045
  def __ne__(self, other):
2046
    return not (self == other)
2047
 
3376 rajveer 2048
class getLastEmailProcessedTimestamp_args:
3131 rajveer 2049
 
3376 rajveer 2050
  thrift_spec = (
2051
  )
2052
 
2053
  def read(self, iprot):
2054
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2055
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2056
      return
2057
    iprot.readStructBegin()
2058
    while True:
2059
      (fname, ftype, fid) = iprot.readFieldBegin()
2060
      if ftype == TType.STOP:
2061
        break
2062
      else:
2063
        iprot.skip(ftype)
2064
      iprot.readFieldEnd()
2065
    iprot.readStructEnd()
2066
 
2067
  def write(self, oprot):
2068
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2069
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2070
      return
2071
    oprot.writeStructBegin('getLastEmailProcessedTimestamp_args')
2072
    oprot.writeFieldStop()
2073
    oprot.writeStructEnd()
2074
 
3431 rajveer 2075
  def validate(self):
2076
    return
2077
 
2078
 
3376 rajveer 2079
  def __repr__(self):
2080
    L = ['%s=%r' % (key, value)
2081
      for key, value in self.__dict__.iteritems()]
2082
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2083
 
2084
  def __eq__(self, other):
2085
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2086
 
2087
  def __ne__(self, other):
2088
    return not (self == other)
2089
 
2090
class getLastEmailProcessedTimestamp_result:
2091
  """
2092
  Attributes:
2093
   - success
2094
  """
2095
 
2096
  thrift_spec = (
2097
    (0, TType.I64, 'success', None, None, ), # 0
2098
  )
2099
 
2100
  def __init__(self, success=None,):
2101
    self.success = success
2102
 
2103
  def read(self, iprot):
2104
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2105
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2106
      return
2107
    iprot.readStructBegin()
2108
    while True:
2109
      (fname, ftype, fid) = iprot.readFieldBegin()
2110
      if ftype == TType.STOP:
2111
        break
2112
      if fid == 0:
2113
        if ftype == TType.I64:
2114
          self.success = iprot.readI64();
2115
        else:
2116
          iprot.skip(ftype)
2117
      else:
2118
        iprot.skip(ftype)
2119
      iprot.readFieldEnd()
2120
    iprot.readStructEnd()
2121
 
2122
  def write(self, oprot):
2123
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2124
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2125
      return
2126
    oprot.writeStructBegin('getLastEmailProcessedTimestamp_result')
3431 rajveer 2127
    if self.success is not None:
3376 rajveer 2128
      oprot.writeFieldBegin('success', TType.I64, 0)
2129
      oprot.writeI64(self.success)
2130
      oprot.writeFieldEnd()
2131
    oprot.writeFieldStop()
2132
    oprot.writeStructEnd()
2133
 
3431 rajveer 2134
  def validate(self):
2135
    return
2136
 
2137
 
3376 rajveer 2138
  def __repr__(self):
2139
    L = ['%s=%r' % (key, value)
2140
      for key, value in self.__dict__.iteritems()]
2141
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2142
 
2143
  def __eq__(self, other):
2144
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2145
 
2146
  def __ne__(self, other):
2147
    return not (self == other)
2148
 
2149
class updateLastEmailProcessedTimestamp_args:
2150
  """
2151
  Attributes:
2152
   - timestamp
2153
  """
2154
 
2155
  thrift_spec = (
2156
    None, # 0
2157
    (1, TType.I64, 'timestamp', None, None, ), # 1
2158
  )
2159
 
2160
  def __init__(self, timestamp=None,):
2161
    self.timestamp = timestamp
2162
 
2163
  def read(self, iprot):
2164
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2165
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2166
      return
2167
    iprot.readStructBegin()
2168
    while True:
2169
      (fname, ftype, fid) = iprot.readFieldBegin()
2170
      if ftype == TType.STOP:
2171
        break
2172
      if fid == 1:
2173
        if ftype == TType.I64:
2174
          self.timestamp = iprot.readI64();
2175
        else:
2176
          iprot.skip(ftype)
2177
      else:
2178
        iprot.skip(ftype)
2179
      iprot.readFieldEnd()
2180
    iprot.readStructEnd()
2181
 
2182
  def write(self, oprot):
2183
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2184
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2185
      return
2186
    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_args')
3431 rajveer 2187
    if self.timestamp is not None:
3376 rajveer 2188
      oprot.writeFieldBegin('timestamp', TType.I64, 1)
2189
      oprot.writeI64(self.timestamp)
2190
      oprot.writeFieldEnd()
2191
    oprot.writeFieldStop()
2192
    oprot.writeStructEnd()
2193
 
3431 rajveer 2194
  def validate(self):
2195
    return
2196
 
2197
 
3376 rajveer 2198
  def __repr__(self):
2199
    L = ['%s=%r' % (key, value)
2200
      for key, value in self.__dict__.iteritems()]
2201
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2202
 
2203
  def __eq__(self, other):
2204
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2205
 
2206
  def __ne__(self, other):
2207
    return not (self == other)
2208
 
2209
class updateLastEmailProcessedTimestamp_result:
2210
 
2211
  thrift_spec = (
2212
  )
2213
 
2214
  def read(self, iprot):
2215
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2216
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2217
      return
2218
    iprot.readStructBegin()
2219
    while True:
2220
      (fname, ftype, fid) = iprot.readFieldBegin()
2221
      if ftype == TType.STOP:
2222
        break
2223
      else:
2224
        iprot.skip(ftype)
2225
      iprot.readFieldEnd()
2226
    iprot.readStructEnd()
2227
 
2228
  def write(self, oprot):
2229
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2230
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2231
      return
2232
    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_result')
2233
    oprot.writeFieldStop()
2234
    oprot.writeStructEnd()
2235
 
3431 rajveer 2236
  def validate(self):
2237
    return
2238
 
2239
 
3376 rajveer 2240
  def __repr__(self):
2241
    L = ['%s=%r' % (key, value)
2242
      for key, value in self.__dict__.iteritems()]
2243
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2244
 
2245
  def __eq__(self, other):
2246
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2247
 
2248
  def __ne__(self, other):
2249
    return not (self == other)
3499 mandeep.dh 2250
 
2251
class processCODTxn_args:
2252
  """
2253
  Attributes:
2254
   - transactionId
2255
  """
2256
 
2257
  thrift_spec = (
2258
    None, # 0
2259
    (1, TType.I64, 'transactionId', None, None, ), # 1
2260
  )
2261
 
2262
  def __init__(self, transactionId=None,):
2263
    self.transactionId = transactionId
2264
 
2265
  def read(self, iprot):
2266
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2267
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2268
      return
2269
    iprot.readStructBegin()
2270
    while True:
2271
      (fname, ftype, fid) = iprot.readFieldBegin()
2272
      if ftype == TType.STOP:
2273
        break
2274
      if fid == 1:
2275
        if ftype == TType.I64:
2276
          self.transactionId = iprot.readI64();
2277
        else:
2278
          iprot.skip(ftype)
2279
      else:
2280
        iprot.skip(ftype)
2281
      iprot.readFieldEnd()
2282
    iprot.readStructEnd()
2283
 
2284
  def write(self, oprot):
2285
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2286
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2287
      return
2288
    oprot.writeStructBegin('processCODTxn_args')
2289
    if self.transactionId is not None:
2290
      oprot.writeFieldBegin('transactionId', TType.I64, 1)
2291
      oprot.writeI64(self.transactionId)
2292
      oprot.writeFieldEnd()
2293
    oprot.writeFieldStop()
2294
    oprot.writeStructEnd()
2295
 
2296
  def validate(self):
2297
    return
2298
 
2299
 
2300
  def __repr__(self):
2301
    L = ['%s=%r' % (key, value)
2302
      for key, value in self.__dict__.iteritems()]
2303
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2304
 
2305
  def __eq__(self, other):
2306
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2307
 
2308
  def __ne__(self, other):
2309
    return not (self == other)