Subversion Repositories SmartDukaan

Rev

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