Subversion Repositories SmartDukaan

Rev

Rev 5407 | Rev 8369 | 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
 
5407 amar.kumar 82
  def getInactiveAgents(self, searchFilter):
83
    """
84
    Parameters:
85
     - searchFilter
86
    """
87
    pass
88
 
3131 rajveer 89
  def updatePasswordForAgent(self, agentEmailId, password):
90
    """
91
    Parameters:
92
     - agentEmailId
93
     - password
94
    """
95
    pass
96
 
97
  def getRoleNamesForAgent(self, agentEmailId):
98
    """
99
    Parameters:
100
     - agentEmailId
101
    """
102
    pass
103
 
104
  def getPermissionsForRoleName(self, roleName):
105
    """
106
    Parameters:
107
     - roleName
108
    """
109
    pass
110
 
3376 rajveer 111
  def getLastEmailProcessedTimestamp(self, ):
112
    pass
3131 rajveer 113
 
3376 rajveer 114
  def updateLastEmailProcessedTimestamp(self, timestamp):
115
    """
116
    Parameters:
117
     - timestamp
118
    """
119
    pass
120
 
4948 phani.kuma 121
  def changeAgentStatus(self, status, emailId):
122
    """
123
    Parameters:
124
     - status
125
     - emailId
126
    """
127
    pass
3376 rajveer 128
 
4948 phani.kuma 129
  def insertAgent(self, agent, role):
130
    """
131
    Parameters:
132
     - agent
133
     - role
134
    """
135
    pass
136
 
5407 amar.kumar 137
  def changeAgentRole(self, id, role):
138
    """
139
    Parameters:
140
     - id
141
     - role
142
    """
143
    pass
4948 phani.kuma 144
 
5407 amar.kumar 145
  def getOpenTicketCountForAgent(self, agentId):
146
    """
147
    Parameters:
148
     - agentId
149
    """
150
    pass
151
 
6104 rajveer 152
  def getOpenTicketsMap(self, ):
153
    pass
5407 amar.kumar 154
 
6104 rajveer 155
 
3376 rajveer 156
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
3131 rajveer 157
  def __init__(self, iprot, oprot=None):
3376 rajveer 158
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
3131 rajveer 159
 
3431 rajveer 160
  def getTickets(self, searchFilter):
3131 rajveer 161
    """
162
    Parameters:
3431 rajveer 163
     - searchFilter
3131 rajveer 164
    """
3431 rajveer 165
    self.send_getTickets(searchFilter)
3131 rajveer 166
    return self.recv_getTickets()
167
 
3431 rajveer 168
  def send_getTickets(self, searchFilter):
3131 rajveer 169
    self._oprot.writeMessageBegin('getTickets', TMessageType.CALL, self._seqid)
170
    args = getTickets_args()
3431 rajveer 171
    args.searchFilter = searchFilter
3131 rajveer 172
    args.write(self._oprot)
173
    self._oprot.writeMessageEnd()
174
    self._oprot.trans.flush()
175
 
176
  def recv_getTickets(self, ):
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
183
    result = getTickets_result()
184
    result.read(self._iprot)
185
    self._iprot.readMessageEnd()
3431 rajveer 186
    if result.success is not None:
3131 rajveer 187
      return result.success
188
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getTickets failed: unknown result");
189
 
3376 rajveer 190
  def getUnassignedTickets(self, ):
191
    self.send_getUnassignedTickets()
192
    return self.recv_getUnassignedTickets()
3131 rajveer 193
 
3376 rajveer 194
  def send_getUnassignedTickets(self, ):
195
    self._oprot.writeMessageBegin('getUnassignedTickets', TMessageType.CALL, self._seqid)
196
    args = getUnassignedTickets_args()
3131 rajveer 197
    args.write(self._oprot)
198
    self._oprot.writeMessageEnd()
199
    self._oprot.trans.flush()
200
 
3376 rajveer 201
  def recv_getUnassignedTickets(self, ):
3131 rajveer 202
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
203
    if mtype == TMessageType.EXCEPTION:
204
      x = TApplicationException()
205
      x.read(self._iprot)
206
      self._iprot.readMessageEnd()
207
      raise x
3376 rajveer 208
    result = getUnassignedTickets_result()
3131 rajveer 209
    result.read(self._iprot)
210
    self._iprot.readMessageEnd()
3431 rajveer 211
    if result.success is not None:
3131 rajveer 212
      return result.success
3376 rajveer 213
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnassignedTickets failed: unknown result");
3131 rajveer 214
 
3376 rajveer 215
  def updateTicket(self, ticket, activity):
3131 rajveer 216
    """
217
    Parameters:
218
     - ticket
3376 rajveer 219
     - activity
3131 rajveer 220
    """
3376 rajveer 221
    self.send_updateTicket(ticket, activity)
3131 rajveer 222
    self.recv_updateTicket()
223
 
3376 rajveer 224
  def send_updateTicket(self, ticket, activity):
3131 rajveer 225
    self._oprot.writeMessageBegin('updateTicket', TMessageType.CALL, self._seqid)
226
    args = updateTicket_args()
227
    args.ticket = ticket
3376 rajveer 228
    args.activity = activity
3131 rajveer 229
    args.write(self._oprot)
230
    self._oprot.writeMessageEnd()
231
    self._oprot.trans.flush()
232
 
233
  def recv_updateTicket(self, ):
234
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
235
    if mtype == TMessageType.EXCEPTION:
236
      x = TApplicationException()
237
      x.read(self._iprot)
238
      self._iprot.readMessageEnd()
239
      raise x
240
    result = updateTicket_result()
241
    result.read(self._iprot)
242
    self._iprot.readMessageEnd()
243
    return
244
 
3376 rajveer 245
  def insertTicket(self, ticket, activity):
3131 rajveer 246
    """
247
    Parameters:
248
     - ticket
3376 rajveer 249
     - activity
3131 rajveer 250
    """
3376 rajveer 251
    self.send_insertTicket(ticket, activity)
3131 rajveer 252
    return self.recv_insertTicket()
253
 
3376 rajveer 254
  def send_insertTicket(self, ticket, activity):
3131 rajveer 255
    self._oprot.writeMessageBegin('insertTicket', TMessageType.CALL, self._seqid)
256
    args = insertTicket_args()
257
    args.ticket = ticket
3376 rajveer 258
    args.activity = activity
3131 rajveer 259
    args.write(self._oprot)
260
    self._oprot.writeMessageEnd()
261
    self._oprot.trans.flush()
262
 
263
  def recv_insertTicket(self, ):
264
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
265
    if mtype == TMessageType.EXCEPTION:
266
      x = TApplicationException()
267
      x.read(self._iprot)
268
      self._iprot.readMessageEnd()
269
      raise x
270
    result = insertTicket_result()
271
    result.read(self._iprot)
272
    self._iprot.readMessageEnd()
3431 rajveer 273
    if result.success is not None:
3131 rajveer 274
      return result.success
275
    raise TApplicationException(TApplicationException.MISSING_RESULT, "insertTicket failed: unknown result");
276
 
4948 phani.kuma 277
  def unassignAgentTickets(self, assigneeId):
278
    """
279
    Parameters:
280
     - assigneeId
281
    """
282
    self.send_unassignAgentTickets(assigneeId)
283
    self.recv_unassignAgentTickets()
284
 
285
  def send_unassignAgentTickets(self, assigneeId):
286
    self._oprot.writeMessageBegin('unassignAgentTickets', TMessageType.CALL, self._seqid)
287
    args = unassignAgentTickets_args()
288
    args.assigneeId = assigneeId
289
    args.write(self._oprot)
290
    self._oprot.writeMessageEnd()
291
    self._oprot.trans.flush()
292
 
293
  def recv_unassignAgentTickets(self, ):
294
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
295
    if mtype == TMessageType.EXCEPTION:
296
      x = TApplicationException()
297
      x.read(self._iprot)
298
      self._iprot.readMessageEnd()
299
      raise x
300
    result = unassignAgentTickets_result()
301
    result.read(self._iprot)
302
    self._iprot.readMessageEnd()
303
    return
304
 
3431 rajveer 305
  def getActivities(self, searchFilter):
3131 rajveer 306
    """
307
    Parameters:
3431 rajveer 308
     - searchFilter
3131 rajveer 309
    """
3431 rajveer 310
    self.send_getActivities(searchFilter)
3131 rajveer 311
    return self.recv_getActivities()
312
 
3431 rajveer 313
  def send_getActivities(self, searchFilter):
3131 rajveer 314
    self._oprot.writeMessageBegin('getActivities', TMessageType.CALL, self._seqid)
315
    args = getActivities_args()
3431 rajveer 316
    args.searchFilter = searchFilter
3131 rajveer 317
    args.write(self._oprot)
318
    self._oprot.writeMessageEnd()
319
    self._oprot.trans.flush()
320
 
321
  def recv_getActivities(self, ):
322
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
323
    if mtype == TMessageType.EXCEPTION:
324
      x = TApplicationException()
325
      x.read(self._iprot)
326
      self._iprot.readMessageEnd()
327
      raise x
328
    result = getActivities_result()
329
    result.read(self._iprot)
330
    self._iprot.readMessageEnd()
3431 rajveer 331
    if result.success is not None:
3131 rajveer 332
      return result.success
333
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getActivities failed: unknown result");
334
 
335
  def insertActivity(self, activity):
336
    """
337
    Parameters:
338
     - activity
339
    """
340
    self.send_insertActivity(activity)
3431 rajveer 341
    return self.recv_insertActivity()
3131 rajveer 342
 
343
  def send_insertActivity(self, activity):
344
    self._oprot.writeMessageBegin('insertActivity', TMessageType.CALL, self._seqid)
345
    args = insertActivity_args()
346
    args.activity = activity
347
    args.write(self._oprot)
348
    self._oprot.writeMessageEnd()
349
    self._oprot.trans.flush()
350
 
351
  def recv_insertActivity(self, ):
352
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
353
    if mtype == TMessageType.EXCEPTION:
354
      x = TApplicationException()
355
      x.read(self._iprot)
356
      self._iprot.readMessageEnd()
357
      raise x
358
    result = insertActivity_result()
359
    result.read(self._iprot)
360
    self._iprot.readMessageEnd()
3431 rajveer 361
    if result.success is not None:
3131 rajveer 362
      return result.success
3431 rajveer 363
    raise TApplicationException(TApplicationException.MISSING_RESULT, "insertActivity failed: unknown result");
3131 rajveer 364
 
3431 rajveer 365
  def markAsRead(self, activityId, agentId):
3131 rajveer 366
    """
367
    Parameters:
3431 rajveer 368
     - activityId
3131 rajveer 369
     - agentId
370
    """
3431 rajveer 371
    self.send_markAsRead(activityId, agentId)
372
    self.recv_markAsRead()
3131 rajveer 373
 
3431 rajveer 374
  def send_markAsRead(self, activityId, agentId):
375
    self._oprot.writeMessageBegin('markAsRead', TMessageType.CALL, self._seqid)
376
    args = markAsRead_args()
377
    args.activityId = activityId
3131 rajveer 378
    args.agentId = agentId
379
    args.write(self._oprot)
380
    self._oprot.writeMessageEnd()
381
    self._oprot.trans.flush()
382
 
3431 rajveer 383
  def recv_markAsRead(self, ):
3131 rajveer 384
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
385
    if mtype == TMessageType.EXCEPTION:
386
      x = TApplicationException()
387
      x.read(self._iprot)
388
      self._iprot.readMessageEnd()
389
      raise x
3431 rajveer 390
    result = markAsRead_result()
3131 rajveer 391
    result.read(self._iprot)
392
    self._iprot.readMessageEnd()
3431 rajveer 393
    return
3131 rajveer 394
 
3431 rajveer 395
  def getAgents(self, searchFilter):
3131 rajveer 396
    """
397
    Parameters:
3431 rajveer 398
     - searchFilter
3131 rajveer 399
    """
3431 rajveer 400
    self.send_getAgents(searchFilter)
401
    return self.recv_getAgents()
3131 rajveer 402
 
3431 rajveer 403
  def send_getAgents(self, searchFilter):
404
    self._oprot.writeMessageBegin('getAgents', TMessageType.CALL, self._seqid)
405
    args = getAgents_args()
406
    args.searchFilter = searchFilter
3131 rajveer 407
    args.write(self._oprot)
408
    self._oprot.writeMessageEnd()
409
    self._oprot.trans.flush()
410
 
3431 rajveer 411
  def recv_getAgents(self, ):
3131 rajveer 412
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
413
    if mtype == TMessageType.EXCEPTION:
414
      x = TApplicationException()
415
      x.read(self._iprot)
416
      self._iprot.readMessageEnd()
417
      raise x
3431 rajveer 418
    result = getAgents_result()
3131 rajveer 419
    result.read(self._iprot)
420
    self._iprot.readMessageEnd()
3431 rajveer 421
    if result.success is not None:
3131 rajveer 422
      return result.success
3431 rajveer 423
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAgents failed: unknown result");
3131 rajveer 424
 
5407 amar.kumar 425
  def getInactiveAgents(self, searchFilter):
426
    """
427
    Parameters:
428
     - searchFilter
429
    """
430
    self.send_getInactiveAgents(searchFilter)
431
    return self.recv_getInactiveAgents()
432
 
433
  def send_getInactiveAgents(self, searchFilter):
434
    self._oprot.writeMessageBegin('getInactiveAgents', TMessageType.CALL, self._seqid)
435
    args = getInactiveAgents_args()
436
    args.searchFilter = searchFilter
437
    args.write(self._oprot)
438
    self._oprot.writeMessageEnd()
439
    self._oprot.trans.flush()
440
 
441
  def recv_getInactiveAgents(self, ):
442
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
443
    if mtype == TMessageType.EXCEPTION:
444
      x = TApplicationException()
445
      x.read(self._iprot)
446
      self._iprot.readMessageEnd()
447
      raise x
448
    result = getInactiveAgents_result()
449
    result.read(self._iprot)
450
    self._iprot.readMessageEnd()
451
    if result.success is not None:
452
      return result.success
453
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getInactiveAgents failed: unknown result");
454
 
3131 rajveer 455
  def updatePasswordForAgent(self, agentEmailId, password):
456
    """
457
    Parameters:
458
     - agentEmailId
459
     - password
460
    """
461
    self.send_updatePasswordForAgent(agentEmailId, password)
462
    self.recv_updatePasswordForAgent()
463
 
464
  def send_updatePasswordForAgent(self, agentEmailId, password):
465
    self._oprot.writeMessageBegin('updatePasswordForAgent', TMessageType.CALL, self._seqid)
466
    args = updatePasswordForAgent_args()
467
    args.agentEmailId = agentEmailId
468
    args.password = password
469
    args.write(self._oprot)
470
    self._oprot.writeMessageEnd()
471
    self._oprot.trans.flush()
472
 
473
  def recv_updatePasswordForAgent(self, ):
474
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
475
    if mtype == TMessageType.EXCEPTION:
476
      x = TApplicationException()
477
      x.read(self._iprot)
478
      self._iprot.readMessageEnd()
479
      raise x
480
    result = updatePasswordForAgent_result()
481
    result.read(self._iprot)
482
    self._iprot.readMessageEnd()
483
    return
484
 
485
  def getRoleNamesForAgent(self, agentEmailId):
486
    """
487
    Parameters:
488
     - agentEmailId
489
    """
490
    self.send_getRoleNamesForAgent(agentEmailId)
491
    return self.recv_getRoleNamesForAgent()
492
 
493
  def send_getRoleNamesForAgent(self, agentEmailId):
494
    self._oprot.writeMessageBegin('getRoleNamesForAgent', TMessageType.CALL, self._seqid)
495
    args = getRoleNamesForAgent_args()
496
    args.agentEmailId = agentEmailId
497
    args.write(self._oprot)
498
    self._oprot.writeMessageEnd()
499
    self._oprot.trans.flush()
500
 
501
  def recv_getRoleNamesForAgent(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 = getRoleNamesForAgent_result()
509
    result.read(self._iprot)
510
    self._iprot.readMessageEnd()
3431 rajveer 511
    if result.success is not None:
3131 rajveer 512
      return result.success
513
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getRoleNamesForAgent failed: unknown result");
514
 
515
  def getPermissionsForRoleName(self, roleName):
516
    """
517
    Parameters:
518
     - roleName
519
    """
520
    self.send_getPermissionsForRoleName(roleName)
521
    return self.recv_getPermissionsForRoleName()
522
 
523
  def send_getPermissionsForRoleName(self, roleName):
524
    self._oprot.writeMessageBegin('getPermissionsForRoleName', TMessageType.CALL, self._seqid)
525
    args = getPermissionsForRoleName_args()
526
    args.roleName = roleName
527
    args.write(self._oprot)
528
    self._oprot.writeMessageEnd()
529
    self._oprot.trans.flush()
530
 
531
  def recv_getPermissionsForRoleName(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 = getPermissionsForRoleName_result()
539
    result.read(self._iprot)
540
    self._iprot.readMessageEnd()
3431 rajveer 541
    if result.success is not None:
3131 rajveer 542
      return result.success
543
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getPermissionsForRoleName failed: unknown result");
544
 
3376 rajveer 545
  def getLastEmailProcessedTimestamp(self, ):
546
    self.send_getLastEmailProcessedTimestamp()
547
    return self.recv_getLastEmailProcessedTimestamp()
3131 rajveer 548
 
3376 rajveer 549
  def send_getLastEmailProcessedTimestamp(self, ):
550
    self._oprot.writeMessageBegin('getLastEmailProcessedTimestamp', TMessageType.CALL, self._seqid)
551
    args = getLastEmailProcessedTimestamp_args()
552
    args.write(self._oprot)
553
    self._oprot.writeMessageEnd()
554
    self._oprot.trans.flush()
555
 
556
  def recv_getLastEmailProcessedTimestamp(self, ):
557
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
558
    if mtype == TMessageType.EXCEPTION:
559
      x = TApplicationException()
560
      x.read(self._iprot)
561
      self._iprot.readMessageEnd()
562
      raise x
563
    result = getLastEmailProcessedTimestamp_result()
564
    result.read(self._iprot)
565
    self._iprot.readMessageEnd()
3431 rajveer 566
    if result.success is not None:
3376 rajveer 567
      return result.success
568
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getLastEmailProcessedTimestamp failed: unknown result");
569
 
570
  def updateLastEmailProcessedTimestamp(self, timestamp):
571
    """
572
    Parameters:
573
     - timestamp
574
    """
575
    self.send_updateLastEmailProcessedTimestamp(timestamp)
576
    self.recv_updateLastEmailProcessedTimestamp()
577
 
578
  def send_updateLastEmailProcessedTimestamp(self, timestamp):
579
    self._oprot.writeMessageBegin('updateLastEmailProcessedTimestamp', TMessageType.CALL, self._seqid)
580
    args = updateLastEmailProcessedTimestamp_args()
581
    args.timestamp = timestamp
582
    args.write(self._oprot)
583
    self._oprot.writeMessageEnd()
584
    self._oprot.trans.flush()
585
 
586
  def recv_updateLastEmailProcessedTimestamp(self, ):
587
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
588
    if mtype == TMessageType.EXCEPTION:
589
      x = TApplicationException()
590
      x.read(self._iprot)
591
      self._iprot.readMessageEnd()
592
      raise x
593
    result = updateLastEmailProcessedTimestamp_result()
594
    result.read(self._iprot)
595
    self._iprot.readMessageEnd()
596
    return
597
 
4948 phani.kuma 598
  def changeAgentStatus(self, status, emailId):
599
    """
600
    Parameters:
601
     - status
602
     - emailId
603
    """
604
    self.send_changeAgentStatus(status, emailId)
605
    self.recv_changeAgentStatus()
3376 rajveer 606
 
4948 phani.kuma 607
  def send_changeAgentStatus(self, status, emailId):
608
    self._oprot.writeMessageBegin('changeAgentStatus', TMessageType.CALL, self._seqid)
609
    args = changeAgentStatus_args()
610
    args.status = status
611
    args.emailId = emailId
612
    args.write(self._oprot)
613
    self._oprot.writeMessageEnd()
614
    self._oprot.trans.flush()
615
 
616
  def recv_changeAgentStatus(self, ):
617
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
618
    if mtype == TMessageType.EXCEPTION:
619
      x = TApplicationException()
620
      x.read(self._iprot)
621
      self._iprot.readMessageEnd()
622
      raise x
623
    result = changeAgentStatus_result()
624
    result.read(self._iprot)
625
    self._iprot.readMessageEnd()
626
    return
627
 
628
  def insertAgent(self, agent, role):
629
    """
630
    Parameters:
631
     - agent
632
     - role
633
    """
634
    self.send_insertAgent(agent, role)
635
    self.recv_insertAgent()
636
 
637
  def send_insertAgent(self, agent, role):
638
    self._oprot.writeMessageBegin('insertAgent', TMessageType.CALL, self._seqid)
639
    args = insertAgent_args()
640
    args.agent = agent
641
    args.role = role
642
    args.write(self._oprot)
643
    self._oprot.writeMessageEnd()
644
    self._oprot.trans.flush()
645
 
646
  def recv_insertAgent(self, ):
647
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
648
    if mtype == TMessageType.EXCEPTION:
649
      x = TApplicationException()
650
      x.read(self._iprot)
651
      self._iprot.readMessageEnd()
652
      raise x
653
    result = insertAgent_result()
654
    result.read(self._iprot)
655
    self._iprot.readMessageEnd()
656
    return
657
 
5407 amar.kumar 658
  def changeAgentRole(self, id, role):
659
    """
660
    Parameters:
661
     - id
662
     - role
663
    """
664
    self.send_changeAgentRole(id, role)
665
    self.recv_changeAgentRole()
4948 phani.kuma 666
 
5407 amar.kumar 667
  def send_changeAgentRole(self, id, role):
668
    self._oprot.writeMessageBegin('changeAgentRole', TMessageType.CALL, self._seqid)
669
    args = changeAgentRole_args()
670
    args.id = id
671
    args.role = role
672
    args.write(self._oprot)
673
    self._oprot.writeMessageEnd()
674
    self._oprot.trans.flush()
675
 
676
  def recv_changeAgentRole(self, ):
677
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
678
    if mtype == TMessageType.EXCEPTION:
679
      x = TApplicationException()
680
      x.read(self._iprot)
681
      self._iprot.readMessageEnd()
682
      raise x
683
    result = changeAgentRole_result()
684
    result.read(self._iprot)
685
    self._iprot.readMessageEnd()
686
    return
687
 
688
  def getOpenTicketCountForAgent(self, agentId):
689
    """
690
    Parameters:
691
     - agentId
692
    """
693
    self.send_getOpenTicketCountForAgent(agentId)
694
    return self.recv_getOpenTicketCountForAgent()
695
 
696
  def send_getOpenTicketCountForAgent(self, agentId):
697
    self._oprot.writeMessageBegin('getOpenTicketCountForAgent', TMessageType.CALL, self._seqid)
698
    args = getOpenTicketCountForAgent_args()
699
    args.agentId = agentId
700
    args.write(self._oprot)
701
    self._oprot.writeMessageEnd()
702
    self._oprot.trans.flush()
703
 
704
  def recv_getOpenTicketCountForAgent(self, ):
705
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
706
    if mtype == TMessageType.EXCEPTION:
707
      x = TApplicationException()
708
      x.read(self._iprot)
709
      self._iprot.readMessageEnd()
710
      raise x
711
    result = getOpenTicketCountForAgent_result()
712
    result.read(self._iprot)
713
    self._iprot.readMessageEnd()
714
    if result.success is not None:
715
      return result.success
716
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getOpenTicketCountForAgent failed: unknown result");
717
 
6104 rajveer 718
  def getOpenTicketsMap(self, ):
719
    self.send_getOpenTicketsMap()
720
    return self.recv_getOpenTicketsMap()
5407 amar.kumar 721
 
6104 rajveer 722
  def send_getOpenTicketsMap(self, ):
723
    self._oprot.writeMessageBegin('getOpenTicketsMap', TMessageType.CALL, self._seqid)
724
    args = getOpenTicketsMap_args()
725
    args.write(self._oprot)
726
    self._oprot.writeMessageEnd()
727
    self._oprot.trans.flush()
728
 
729
  def recv_getOpenTicketsMap(self, ):
730
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
731
    if mtype == TMessageType.EXCEPTION:
732
      x = TApplicationException()
733
      x.read(self._iprot)
734
      self._iprot.readMessageEnd()
735
      raise x
736
    result = getOpenTicketsMap_result()
737
    result.read(self._iprot)
738
    self._iprot.readMessageEnd()
739
    if result.success is not None:
740
      return result.success
741
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getOpenTicketsMap failed: unknown result");
742
 
743
 
3376 rajveer 744
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
3131 rajveer 745
  def __init__(self, handler):
3376 rajveer 746
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
3131 rajveer 747
    self._processMap["getTickets"] = Processor.process_getTickets
3376 rajveer 748
    self._processMap["getUnassignedTickets"] = Processor.process_getUnassignedTickets
3131 rajveer 749
    self._processMap["updateTicket"] = Processor.process_updateTicket
750
    self._processMap["insertTicket"] = Processor.process_insertTicket
4948 phani.kuma 751
    self._processMap["unassignAgentTickets"] = Processor.process_unassignAgentTickets
3131 rajveer 752
    self._processMap["getActivities"] = Processor.process_getActivities
753
    self._processMap["insertActivity"] = Processor.process_insertActivity
3431 rajveer 754
    self._processMap["markAsRead"] = Processor.process_markAsRead
755
    self._processMap["getAgents"] = Processor.process_getAgents
5407 amar.kumar 756
    self._processMap["getInactiveAgents"] = Processor.process_getInactiveAgents
3131 rajveer 757
    self._processMap["updatePasswordForAgent"] = Processor.process_updatePasswordForAgent
758
    self._processMap["getRoleNamesForAgent"] = Processor.process_getRoleNamesForAgent
759
    self._processMap["getPermissionsForRoleName"] = Processor.process_getPermissionsForRoleName
3376 rajveer 760
    self._processMap["getLastEmailProcessedTimestamp"] = Processor.process_getLastEmailProcessedTimestamp
761
    self._processMap["updateLastEmailProcessedTimestamp"] = Processor.process_updateLastEmailProcessedTimestamp
4948 phani.kuma 762
    self._processMap["changeAgentStatus"] = Processor.process_changeAgentStatus
763
    self._processMap["insertAgent"] = Processor.process_insertAgent
5407 amar.kumar 764
    self._processMap["changeAgentRole"] = Processor.process_changeAgentRole
765
    self._processMap["getOpenTicketCountForAgent"] = Processor.process_getOpenTicketCountForAgent
6104 rajveer 766
    self._processMap["getOpenTicketsMap"] = Processor.process_getOpenTicketsMap
3131 rajveer 767
 
768
  def process(self, iprot, oprot):
769
    (name, type, seqid) = iprot.readMessageBegin()
770
    if name not in self._processMap:
771
      iprot.skip(TType.STRUCT)
772
      iprot.readMessageEnd()
773
      x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
774
      oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
775
      x.write(oprot)
776
      oprot.writeMessageEnd()
777
      oprot.trans.flush()
778
      return
779
    else:
780
      self._processMap[name](self, seqid, iprot, oprot)
781
    return True
782
 
783
  def process_getTickets(self, seqid, iprot, oprot):
784
    args = getTickets_args()
785
    args.read(iprot)
786
    iprot.readMessageEnd()
787
    result = getTickets_result()
3431 rajveer 788
    result.success = self._handler.getTickets(args.searchFilter)
3131 rajveer 789
    oprot.writeMessageBegin("getTickets", TMessageType.REPLY, seqid)
790
    result.write(oprot)
791
    oprot.writeMessageEnd()
792
    oprot.trans.flush()
793
 
3376 rajveer 794
  def process_getUnassignedTickets(self, seqid, iprot, oprot):
795
    args = getUnassignedTickets_args()
3131 rajveer 796
    args.read(iprot)
797
    iprot.readMessageEnd()
3376 rajveer 798
    result = getUnassignedTickets_result()
799
    result.success = self._handler.getUnassignedTickets()
800
    oprot.writeMessageBegin("getUnassignedTickets", TMessageType.REPLY, seqid)
3131 rajveer 801
    result.write(oprot)
802
    oprot.writeMessageEnd()
803
    oprot.trans.flush()
804
 
805
  def process_updateTicket(self, seqid, iprot, oprot):
806
    args = updateTicket_args()
807
    args.read(iprot)
808
    iprot.readMessageEnd()
809
    result = updateTicket_result()
3376 rajveer 810
    self._handler.updateTicket(args.ticket, args.activity)
3131 rajveer 811
    oprot.writeMessageBegin("updateTicket", TMessageType.REPLY, seqid)
812
    result.write(oprot)
813
    oprot.writeMessageEnd()
814
    oprot.trans.flush()
815
 
816
  def process_insertTicket(self, seqid, iprot, oprot):
817
    args = insertTicket_args()
818
    args.read(iprot)
819
    iprot.readMessageEnd()
820
    result = insertTicket_result()
3376 rajveer 821
    result.success = self._handler.insertTicket(args.ticket, args.activity)
3131 rajveer 822
    oprot.writeMessageBegin("insertTicket", TMessageType.REPLY, seqid)
823
    result.write(oprot)
824
    oprot.writeMessageEnd()
825
    oprot.trans.flush()
826
 
4948 phani.kuma 827
  def process_unassignAgentTickets(self, seqid, iprot, oprot):
828
    args = unassignAgentTickets_args()
829
    args.read(iprot)
830
    iprot.readMessageEnd()
831
    result = unassignAgentTickets_result()
832
    self._handler.unassignAgentTickets(args.assigneeId)
833
    oprot.writeMessageBegin("unassignAgentTickets", TMessageType.REPLY, seqid)
834
    result.write(oprot)
835
    oprot.writeMessageEnd()
836
    oprot.trans.flush()
837
 
3131 rajveer 838
  def process_getActivities(self, seqid, iprot, oprot):
839
    args = getActivities_args()
840
    args.read(iprot)
841
    iprot.readMessageEnd()
842
    result = getActivities_result()
3431 rajveer 843
    result.success = self._handler.getActivities(args.searchFilter)
3131 rajveer 844
    oprot.writeMessageBegin("getActivities", TMessageType.REPLY, seqid)
845
    result.write(oprot)
846
    oprot.writeMessageEnd()
847
    oprot.trans.flush()
848
 
849
  def process_insertActivity(self, seqid, iprot, oprot):
850
    args = insertActivity_args()
851
    args.read(iprot)
852
    iprot.readMessageEnd()
853
    result = insertActivity_result()
3431 rajveer 854
    result.success = self._handler.insertActivity(args.activity)
3131 rajveer 855
    oprot.writeMessageBegin("insertActivity", TMessageType.REPLY, seqid)
856
    result.write(oprot)
857
    oprot.writeMessageEnd()
858
    oprot.trans.flush()
859
 
3431 rajveer 860
  def process_markAsRead(self, seqid, iprot, oprot):
861
    args = markAsRead_args()
3131 rajveer 862
    args.read(iprot)
863
    iprot.readMessageEnd()
3431 rajveer 864
    result = markAsRead_result()
865
    self._handler.markAsRead(args.activityId, args.agentId)
866
    oprot.writeMessageBegin("markAsRead", TMessageType.REPLY, seqid)
3131 rajveer 867
    result.write(oprot)
868
    oprot.writeMessageEnd()
869
    oprot.trans.flush()
870
 
3431 rajveer 871
  def process_getAgents(self, seqid, iprot, oprot):
872
    args = getAgents_args()
3131 rajveer 873
    args.read(iprot)
874
    iprot.readMessageEnd()
3431 rajveer 875
    result = getAgents_result()
876
    result.success = self._handler.getAgents(args.searchFilter)
877
    oprot.writeMessageBegin("getAgents", TMessageType.REPLY, seqid)
3131 rajveer 878
    result.write(oprot)
879
    oprot.writeMessageEnd()
880
    oprot.trans.flush()
881
 
5407 amar.kumar 882
  def process_getInactiveAgents(self, seqid, iprot, oprot):
883
    args = getInactiveAgents_args()
884
    args.read(iprot)
885
    iprot.readMessageEnd()
886
    result = getInactiveAgents_result()
887
    result.success = self._handler.getInactiveAgents(args.searchFilter)
888
    oprot.writeMessageBegin("getInactiveAgents", TMessageType.REPLY, seqid)
889
    result.write(oprot)
890
    oprot.writeMessageEnd()
891
    oprot.trans.flush()
892
 
3131 rajveer 893
  def process_updatePasswordForAgent(self, seqid, iprot, oprot):
894
    args = updatePasswordForAgent_args()
895
    args.read(iprot)
896
    iprot.readMessageEnd()
897
    result = updatePasswordForAgent_result()
898
    self._handler.updatePasswordForAgent(args.agentEmailId, args.password)
899
    oprot.writeMessageBegin("updatePasswordForAgent", TMessageType.REPLY, seqid)
900
    result.write(oprot)
901
    oprot.writeMessageEnd()
902
    oprot.trans.flush()
903
 
904
  def process_getRoleNamesForAgent(self, seqid, iprot, oprot):
905
    args = getRoleNamesForAgent_args()
906
    args.read(iprot)
907
    iprot.readMessageEnd()
908
    result = getRoleNamesForAgent_result()
909
    result.success = self._handler.getRoleNamesForAgent(args.agentEmailId)
910
    oprot.writeMessageBegin("getRoleNamesForAgent", TMessageType.REPLY, seqid)
911
    result.write(oprot)
912
    oprot.writeMessageEnd()
913
    oprot.trans.flush()
914
 
915
  def process_getPermissionsForRoleName(self, seqid, iprot, oprot):
916
    args = getPermissionsForRoleName_args()
917
    args.read(iprot)
918
    iprot.readMessageEnd()
919
    result = getPermissionsForRoleName_result()
920
    result.success = self._handler.getPermissionsForRoleName(args.roleName)
921
    oprot.writeMessageBegin("getPermissionsForRoleName", TMessageType.REPLY, seqid)
922
    result.write(oprot)
923
    oprot.writeMessageEnd()
924
    oprot.trans.flush()
925
 
3376 rajveer 926
  def process_getLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
927
    args = getLastEmailProcessedTimestamp_args()
928
    args.read(iprot)
929
    iprot.readMessageEnd()
930
    result = getLastEmailProcessedTimestamp_result()
931
    result.success = self._handler.getLastEmailProcessedTimestamp()
932
    oprot.writeMessageBegin("getLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
933
    result.write(oprot)
934
    oprot.writeMessageEnd()
935
    oprot.trans.flush()
3131 rajveer 936
 
3376 rajveer 937
  def process_updateLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
938
    args = updateLastEmailProcessedTimestamp_args()
939
    args.read(iprot)
940
    iprot.readMessageEnd()
941
    result = updateLastEmailProcessedTimestamp_result()
942
    self._handler.updateLastEmailProcessedTimestamp(args.timestamp)
943
    oprot.writeMessageBegin("updateLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
944
    result.write(oprot)
945
    oprot.writeMessageEnd()
946
    oprot.trans.flush()
947
 
4948 phani.kuma 948
  def process_changeAgentStatus(self, seqid, iprot, oprot):
949
    args = changeAgentStatus_args()
950
    args.read(iprot)
951
    iprot.readMessageEnd()
952
    result = changeAgentStatus_result()
953
    self._handler.changeAgentStatus(args.status, args.emailId)
954
    oprot.writeMessageBegin("changeAgentStatus", TMessageType.REPLY, seqid)
955
    result.write(oprot)
956
    oprot.writeMessageEnd()
957
    oprot.trans.flush()
3376 rajveer 958
 
4948 phani.kuma 959
  def process_insertAgent(self, seqid, iprot, oprot):
960
    args = insertAgent_args()
961
    args.read(iprot)
962
    iprot.readMessageEnd()
963
    result = insertAgent_result()
964
    self._handler.insertAgent(args.agent, args.role)
965
    oprot.writeMessageBegin("insertAgent", TMessageType.REPLY, seqid)
966
    result.write(oprot)
967
    oprot.writeMessageEnd()
968
    oprot.trans.flush()
969
 
5407 amar.kumar 970
  def process_changeAgentRole(self, seqid, iprot, oprot):
971
    args = changeAgentRole_args()
972
    args.read(iprot)
973
    iprot.readMessageEnd()
974
    result = changeAgentRole_result()
975
    self._handler.changeAgentRole(args.id, args.role)
976
    oprot.writeMessageBegin("changeAgentRole", TMessageType.REPLY, seqid)
977
    result.write(oprot)
978
    oprot.writeMessageEnd()
979
    oprot.trans.flush()
4948 phani.kuma 980
 
5407 amar.kumar 981
  def process_getOpenTicketCountForAgent(self, seqid, iprot, oprot):
982
    args = getOpenTicketCountForAgent_args()
983
    args.read(iprot)
984
    iprot.readMessageEnd()
985
    result = getOpenTicketCountForAgent_result()
986
    result.success = self._handler.getOpenTicketCountForAgent(args.agentId)
987
    oprot.writeMessageBegin("getOpenTicketCountForAgent", TMessageType.REPLY, seqid)
988
    result.write(oprot)
989
    oprot.writeMessageEnd()
990
    oprot.trans.flush()
991
 
6104 rajveer 992
  def process_getOpenTicketsMap(self, seqid, iprot, oprot):
993
    args = getOpenTicketsMap_args()
994
    args.read(iprot)
995
    iprot.readMessageEnd()
996
    result = getOpenTicketsMap_result()
997
    result.success = self._handler.getOpenTicketsMap()
998
    oprot.writeMessageBegin("getOpenTicketsMap", TMessageType.REPLY, seqid)
999
    result.write(oprot)
1000
    oprot.writeMessageEnd()
1001
    oprot.trans.flush()
5407 amar.kumar 1002
 
6104 rajveer 1003
 
3131 rajveer 1004
# HELPER FUNCTIONS AND STRUCTURES
1005
 
1006
class getTickets_args:
1007
  """
1008
  Attributes:
3431 rajveer 1009
   - searchFilter
3131 rajveer 1010
  """
1011
 
1012
  thrift_spec = (
1013
    None, # 0
3431 rajveer 1014
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 1015
  )
1016
 
3431 rajveer 1017
  def __init__(self, searchFilter=None,):
1018
    self.searchFilter = searchFilter
3131 rajveer 1019
 
1020
  def read(self, iprot):
1021
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1022
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1023
      return
1024
    iprot.readStructBegin()
1025
    while True:
1026
      (fname, ftype, fid) = iprot.readFieldBegin()
1027
      if ftype == TType.STOP:
1028
        break
1029
      if fid == 1:
3431 rajveer 1030
        if ftype == TType.STRUCT:
1031
          self.searchFilter = SearchFilter()
1032
          self.searchFilter.read(iprot)
3131 rajveer 1033
        else:
1034
          iprot.skip(ftype)
1035
      else:
1036
        iprot.skip(ftype)
1037
      iprot.readFieldEnd()
1038
    iprot.readStructEnd()
1039
 
1040
  def write(self, oprot):
1041
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1042
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1043
      return
1044
    oprot.writeStructBegin('getTickets_args')
3431 rajveer 1045
    if self.searchFilter is not None:
1046
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
1047
      self.searchFilter.write(oprot)
3131 rajveer 1048
      oprot.writeFieldEnd()
1049
    oprot.writeFieldStop()
1050
    oprot.writeStructEnd()
1051
 
3431 rajveer 1052
  def validate(self):
1053
    return
3131 rajveer 1054
 
1055
 
1056
  def __repr__(self):
1057
    L = ['%s=%r' % (key, value)
1058
      for key, value in self.__dict__.iteritems()]
1059
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1060
 
1061
  def __eq__(self, other):
1062
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1063
 
1064
  def __ne__(self, other):
1065
    return not (self == other)
1066
 
3431 rajveer 1067
class getTickets_result:
3131 rajveer 1068
  """
1069
  Attributes:
1070
   - success
1071
  """
1072
 
1073
  thrift_spec = (
1074
    (0, TType.LIST, 'success', (TType.STRUCT,(Ticket, Ticket.thrift_spec)), None, ), # 0
1075
  )
1076
 
1077
  def __init__(self, success=None,):
1078
    self.success = success
1079
 
1080
  def read(self, iprot):
1081
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1082
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1083
      return
1084
    iprot.readStructBegin()
1085
    while True:
1086
      (fname, ftype, fid) = iprot.readFieldBegin()
1087
      if ftype == TType.STOP:
1088
        break
1089
      if fid == 0:
1090
        if ftype == TType.LIST:
1091
          self.success = []
3546 mandeep.dh 1092
          (_etype24, _size21) = iprot.readListBegin()
1093
          for _i25 in xrange(_size21):
1094
            _elem26 = Ticket()
1095
            _elem26.read(iprot)
1096
            self.success.append(_elem26)
3131 rajveer 1097
          iprot.readListEnd()
1098
        else:
1099
          iprot.skip(ftype)
1100
      else:
1101
        iprot.skip(ftype)
1102
      iprot.readFieldEnd()
1103
    iprot.readStructEnd()
1104
 
1105
  def write(self, oprot):
1106
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1107
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1108
      return
3431 rajveer 1109
    oprot.writeStructBegin('getTickets_result')
1110
    if self.success is not None:
3131 rajveer 1111
      oprot.writeFieldBegin('success', TType.LIST, 0)
1112
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3546 mandeep.dh 1113
      for iter27 in self.success:
1114
        iter27.write(oprot)
3131 rajveer 1115
      oprot.writeListEnd()
1116
      oprot.writeFieldEnd()
1117
    oprot.writeFieldStop()
1118
    oprot.writeStructEnd()
1119
 
3431 rajveer 1120
  def validate(self):
1121
    return
1122
 
1123
 
3131 rajveer 1124
  def __repr__(self):
1125
    L = ['%s=%r' % (key, value)
1126
      for key, value in self.__dict__.iteritems()]
1127
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1128
 
1129
  def __eq__(self, other):
1130
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1131
 
1132
  def __ne__(self, other):
1133
    return not (self == other)
1134
 
3431 rajveer 1135
class getUnassignedTickets_args:
3376 rajveer 1136
 
1137
  thrift_spec = (
1138
  )
1139
 
1140
  def read(self, iprot):
1141
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1142
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1143
      return
1144
    iprot.readStructBegin()
1145
    while True:
1146
      (fname, ftype, fid) = iprot.readFieldBegin()
1147
      if ftype == TType.STOP:
1148
        break
1149
      else:
1150
        iprot.skip(ftype)
1151
      iprot.readFieldEnd()
1152
    iprot.readStructEnd()
1153
 
1154
  def write(self, oprot):
1155
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1156
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1157
      return
3431 rajveer 1158
    oprot.writeStructBegin('getUnassignedTickets_args')
3376 rajveer 1159
    oprot.writeFieldStop()
1160
    oprot.writeStructEnd()
1161
 
3431 rajveer 1162
  def validate(self):
1163
    return
1164
 
1165
 
3376 rajveer 1166
  def __repr__(self):
1167
    L = ['%s=%r' % (key, value)
1168
      for key, value in self.__dict__.iteritems()]
1169
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1170
 
1171
  def __eq__(self, other):
1172
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1173
 
1174
  def __ne__(self, other):
1175
    return not (self == other)
1176
 
3431 rajveer 1177
class getUnassignedTickets_result:
3376 rajveer 1178
  """
1179
  Attributes:
1180
   - success
1181
  """
1182
 
1183
  thrift_spec = (
1184
    (0, TType.LIST, 'success', (TType.STRUCT,(Ticket, Ticket.thrift_spec)), None, ), # 0
1185
  )
1186
 
1187
  def __init__(self, success=None,):
1188
    self.success = success
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 == 0:
1200
        if ftype == TType.LIST:
1201
          self.success = []
3546 mandeep.dh 1202
          (_etype31, _size28) = iprot.readListBegin()
1203
          for _i32 in xrange(_size28):
1204
            _elem33 = Ticket()
1205
            _elem33.read(iprot)
1206
            self.success.append(_elem33)
3376 rajveer 1207
          iprot.readListEnd()
1208
        else:
1209
          iprot.skip(ftype)
1210
      else:
1211
        iprot.skip(ftype)
1212
      iprot.readFieldEnd()
1213
    iprot.readStructEnd()
1214
 
1215
  def write(self, oprot):
1216
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1217
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1218
      return
3431 rajveer 1219
    oprot.writeStructBegin('getUnassignedTickets_result')
1220
    if self.success is not None:
3376 rajveer 1221
      oprot.writeFieldBegin('success', TType.LIST, 0)
1222
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3546 mandeep.dh 1223
      for iter34 in self.success:
1224
        iter34.write(oprot)
3376 rajveer 1225
      oprot.writeListEnd()
1226
      oprot.writeFieldEnd()
1227
    oprot.writeFieldStop()
1228
    oprot.writeStructEnd()
1229
 
3431 rajveer 1230
  def validate(self):
1231
    return
3376 rajveer 1232
 
1233
 
3131 rajveer 1234
  def __repr__(self):
1235
    L = ['%s=%r' % (key, value)
1236
      for key, value in self.__dict__.iteritems()]
1237
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1238
 
1239
  def __eq__(self, other):
1240
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1241
 
1242
  def __ne__(self, other):
1243
    return not (self == other)
1244
 
1245
class updateTicket_args:
1246
  """
1247
  Attributes:
1248
   - ticket
3376 rajveer 1249
   - activity
3131 rajveer 1250
  """
1251
 
1252
  thrift_spec = (
1253
    None, # 0
1254
    (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
3376 rajveer 1255
    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
3131 rajveer 1256
  )
1257
 
3376 rajveer 1258
  def __init__(self, ticket=None, activity=None,):
3131 rajveer 1259
    self.ticket = ticket
3376 rajveer 1260
    self.activity = activity
3131 rajveer 1261
 
1262
  def read(self, iprot):
1263
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1264
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1265
      return
1266
    iprot.readStructBegin()
1267
    while True:
1268
      (fname, ftype, fid) = iprot.readFieldBegin()
1269
      if ftype == TType.STOP:
1270
        break
1271
      if fid == 1:
1272
        if ftype == TType.STRUCT:
1273
          self.ticket = Ticket()
1274
          self.ticket.read(iprot)
1275
        else:
1276
          iprot.skip(ftype)
3376 rajveer 1277
      elif fid == 2:
1278
        if ftype == TType.STRUCT:
1279
          self.activity = Activity()
1280
          self.activity.read(iprot)
1281
        else:
1282
          iprot.skip(ftype)
3131 rajveer 1283
      else:
1284
        iprot.skip(ftype)
1285
      iprot.readFieldEnd()
1286
    iprot.readStructEnd()
1287
 
1288
  def write(self, oprot):
1289
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1290
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1291
      return
1292
    oprot.writeStructBegin('updateTicket_args')
3431 rajveer 1293
    if self.ticket is not None:
3131 rajveer 1294
      oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
1295
      self.ticket.write(oprot)
1296
      oprot.writeFieldEnd()
3431 rajveer 1297
    if self.activity is not None:
3376 rajveer 1298
      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
1299
      self.activity.write(oprot)
1300
      oprot.writeFieldEnd()
3131 rajveer 1301
    oprot.writeFieldStop()
1302
    oprot.writeStructEnd()
1303
 
3431 rajveer 1304
  def validate(self):
1305
    return
1306
 
1307
 
3131 rajveer 1308
  def __repr__(self):
1309
    L = ['%s=%r' % (key, value)
1310
      for key, value in self.__dict__.iteritems()]
1311
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1312
 
1313
  def __eq__(self, other):
1314
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1315
 
1316
  def __ne__(self, other):
1317
    return not (self == other)
1318
 
1319
class updateTicket_result:
1320
 
1321
  thrift_spec = (
1322
  )
1323
 
1324
  def read(self, iprot):
1325
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1326
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1327
      return
1328
    iprot.readStructBegin()
1329
    while True:
1330
      (fname, ftype, fid) = iprot.readFieldBegin()
1331
      if ftype == TType.STOP:
1332
        break
1333
      else:
1334
        iprot.skip(ftype)
1335
      iprot.readFieldEnd()
1336
    iprot.readStructEnd()
1337
 
1338
  def write(self, oprot):
1339
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1340
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1341
      return
1342
    oprot.writeStructBegin('updateTicket_result')
1343
    oprot.writeFieldStop()
1344
    oprot.writeStructEnd()
1345
 
3431 rajveer 1346
  def validate(self):
1347
    return
1348
 
1349
 
3131 rajveer 1350
  def __repr__(self):
1351
    L = ['%s=%r' % (key, value)
1352
      for key, value in self.__dict__.iteritems()]
1353
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1354
 
1355
  def __eq__(self, other):
1356
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1357
 
1358
  def __ne__(self, other):
1359
    return not (self == other)
1360
 
1361
class insertTicket_args:
1362
  """
1363
  Attributes:
1364
   - ticket
3376 rajveer 1365
   - activity
3131 rajveer 1366
  """
1367
 
1368
  thrift_spec = (
1369
    None, # 0
1370
    (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
3376 rajveer 1371
    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
3131 rajveer 1372
  )
1373
 
3376 rajveer 1374
  def __init__(self, ticket=None, activity=None,):
3131 rajveer 1375
    self.ticket = ticket
3376 rajveer 1376
    self.activity = activity
3131 rajveer 1377
 
1378
  def read(self, iprot):
1379
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1380
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1381
      return
1382
    iprot.readStructBegin()
1383
    while True:
1384
      (fname, ftype, fid) = iprot.readFieldBegin()
1385
      if ftype == TType.STOP:
1386
        break
1387
      if fid == 1:
1388
        if ftype == TType.STRUCT:
1389
          self.ticket = Ticket()
1390
          self.ticket.read(iprot)
1391
        else:
1392
          iprot.skip(ftype)
3376 rajveer 1393
      elif fid == 2:
1394
        if ftype == TType.STRUCT:
1395
          self.activity = Activity()
1396
          self.activity.read(iprot)
1397
        else:
1398
          iprot.skip(ftype)
3131 rajveer 1399
      else:
1400
        iprot.skip(ftype)
1401
      iprot.readFieldEnd()
1402
    iprot.readStructEnd()
1403
 
1404
  def write(self, oprot):
1405
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1406
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1407
      return
1408
    oprot.writeStructBegin('insertTicket_args')
3431 rajveer 1409
    if self.ticket is not None:
3131 rajveer 1410
      oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
1411
      self.ticket.write(oprot)
1412
      oprot.writeFieldEnd()
3431 rajveer 1413
    if self.activity is not None:
3376 rajveer 1414
      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
1415
      self.activity.write(oprot)
1416
      oprot.writeFieldEnd()
3131 rajveer 1417
    oprot.writeFieldStop()
1418
    oprot.writeStructEnd()
1419
 
3431 rajveer 1420
  def validate(self):
1421
    return
1422
 
1423
 
3131 rajveer 1424
  def __repr__(self):
1425
    L = ['%s=%r' % (key, value)
1426
      for key, value in self.__dict__.iteritems()]
1427
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1428
 
1429
  def __eq__(self, other):
1430
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1431
 
1432
  def __ne__(self, other):
1433
    return not (self == other)
1434
 
1435
class insertTicket_result:
1436
  """
1437
  Attributes:
1438
   - success
1439
  """
1440
 
1441
  thrift_spec = (
1442
    (0, TType.I64, 'success', None, None, ), # 0
1443
  )
1444
 
1445
  def __init__(self, success=None,):
1446
    self.success = success
1447
 
1448
  def read(self, iprot):
1449
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1450
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1451
      return
1452
    iprot.readStructBegin()
1453
    while True:
1454
      (fname, ftype, fid) = iprot.readFieldBegin()
1455
      if ftype == TType.STOP:
1456
        break
1457
      if fid == 0:
1458
        if ftype == TType.I64:
1459
          self.success = iprot.readI64();
1460
        else:
1461
          iprot.skip(ftype)
1462
      else:
1463
        iprot.skip(ftype)
1464
      iprot.readFieldEnd()
1465
    iprot.readStructEnd()
1466
 
1467
  def write(self, oprot):
1468
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1469
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1470
      return
1471
    oprot.writeStructBegin('insertTicket_result')
3431 rajveer 1472
    if self.success is not None:
3131 rajveer 1473
      oprot.writeFieldBegin('success', TType.I64, 0)
1474
      oprot.writeI64(self.success)
1475
      oprot.writeFieldEnd()
1476
    oprot.writeFieldStop()
1477
    oprot.writeStructEnd()
1478
 
3431 rajveer 1479
  def validate(self):
1480
    return
1481
 
1482
 
3131 rajveer 1483
  def __repr__(self):
1484
    L = ['%s=%r' % (key, value)
1485
      for key, value in self.__dict__.iteritems()]
1486
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1487
 
1488
  def __eq__(self, other):
1489
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1490
 
1491
  def __ne__(self, other):
1492
    return not (self == other)
1493
 
4948 phani.kuma 1494
class unassignAgentTickets_args:
1495
  """
1496
  Attributes:
1497
   - assigneeId
1498
  """
1499
 
1500
  thrift_spec = (
1501
    None, # 0
1502
    (1, TType.I32, 'assigneeId', None, None, ), # 1
1503
  )
1504
 
1505
  def __init__(self, assigneeId=None,):
1506
    self.assigneeId = assigneeId
1507
 
1508
  def read(self, iprot):
1509
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1510
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1511
      return
1512
    iprot.readStructBegin()
1513
    while True:
1514
      (fname, ftype, fid) = iprot.readFieldBegin()
1515
      if ftype == TType.STOP:
1516
        break
1517
      if fid == 1:
1518
        if ftype == TType.I32:
1519
          self.assigneeId = iprot.readI32();
1520
        else:
1521
          iprot.skip(ftype)
1522
      else:
1523
        iprot.skip(ftype)
1524
      iprot.readFieldEnd()
1525
    iprot.readStructEnd()
1526
 
1527
  def write(self, oprot):
1528
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1529
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1530
      return
1531
    oprot.writeStructBegin('unassignAgentTickets_args')
1532
    if self.assigneeId is not None:
1533
      oprot.writeFieldBegin('assigneeId', TType.I32, 1)
1534
      oprot.writeI32(self.assigneeId)
1535
      oprot.writeFieldEnd()
1536
    oprot.writeFieldStop()
1537
    oprot.writeStructEnd()
1538
 
1539
  def validate(self):
1540
    return
1541
 
1542
 
1543
  def __repr__(self):
1544
    L = ['%s=%r' % (key, value)
1545
      for key, value in self.__dict__.iteritems()]
1546
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1547
 
1548
  def __eq__(self, other):
1549
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1550
 
1551
  def __ne__(self, other):
1552
    return not (self == other)
1553
 
1554
class unassignAgentTickets_result:
1555
 
1556
  thrift_spec = (
1557
  )
1558
 
1559
  def read(self, iprot):
1560
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1561
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1562
      return
1563
    iprot.readStructBegin()
1564
    while True:
1565
      (fname, ftype, fid) = iprot.readFieldBegin()
1566
      if ftype == TType.STOP:
1567
        break
1568
      else:
1569
        iprot.skip(ftype)
1570
      iprot.readFieldEnd()
1571
    iprot.readStructEnd()
1572
 
1573
  def write(self, oprot):
1574
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1575
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1576
      return
1577
    oprot.writeStructBegin('unassignAgentTickets_result')
1578
    oprot.writeFieldStop()
1579
    oprot.writeStructEnd()
1580
 
1581
  def validate(self):
1582
    return
1583
 
1584
 
1585
  def __repr__(self):
1586
    L = ['%s=%r' % (key, value)
1587
      for key, value in self.__dict__.iteritems()]
1588
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1589
 
1590
  def __eq__(self, other):
1591
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1592
 
1593
  def __ne__(self, other):
1594
    return not (self == other)
1595
 
3131 rajveer 1596
class getActivities_args:
1597
  """
1598
  Attributes:
3431 rajveer 1599
   - searchFilter
3131 rajveer 1600
  """
1601
 
1602
  thrift_spec = (
1603
    None, # 0
3431 rajveer 1604
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 1605
  )
1606
 
3431 rajveer 1607
  def __init__(self, searchFilter=None,):
1608
    self.searchFilter = searchFilter
3131 rajveer 1609
 
1610
  def read(self, iprot):
1611
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1612
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1613
      return
1614
    iprot.readStructBegin()
1615
    while True:
1616
      (fname, ftype, fid) = iprot.readFieldBegin()
1617
      if ftype == TType.STOP:
1618
        break
1619
      if fid == 1:
3431 rajveer 1620
        if ftype == TType.STRUCT:
1621
          self.searchFilter = SearchFilter()
1622
          self.searchFilter.read(iprot)
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
1634
    oprot.writeStructBegin('getActivities_args')
3431 rajveer 1635
    if self.searchFilter is not None:
1636
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
1637
      self.searchFilter.write(oprot)
3131 rajveer 1638
      oprot.writeFieldEnd()
1639
    oprot.writeFieldStop()
1640
    oprot.writeStructEnd()
1641
 
3431 rajveer 1642
  def validate(self):
1643
    return
1644
 
1645
 
3131 rajveer 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
 
1657
class getActivities_result:
1658
  """
1659
  Attributes:
1660
   - success
1661
  """
1662
 
1663
  thrift_spec = (
1664
    (0, TType.LIST, 'success', (TType.STRUCT,(Activity, Activity.thrift_spec)), None, ), # 0
1665
  )
1666
 
1667
  def __init__(self, success=None,):
1668
    self.success = success
1669
 
1670
  def read(self, iprot):
1671
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1672
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1673
      return
1674
    iprot.readStructBegin()
1675
    while True:
1676
      (fname, ftype, fid) = iprot.readFieldBegin()
1677
      if ftype == TType.STOP:
1678
        break
1679
      if fid == 0:
1680
        if ftype == TType.LIST:
1681
          self.success = []
3546 mandeep.dh 1682
          (_etype38, _size35) = iprot.readListBegin()
1683
          for _i39 in xrange(_size35):
1684
            _elem40 = Activity()
1685
            _elem40.read(iprot)
1686
            self.success.append(_elem40)
3131 rajveer 1687
          iprot.readListEnd()
1688
        else:
1689
          iprot.skip(ftype)
1690
      else:
1691
        iprot.skip(ftype)
1692
      iprot.readFieldEnd()
1693
    iprot.readStructEnd()
1694
 
1695
  def write(self, oprot):
1696
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1697
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1698
      return
1699
    oprot.writeStructBegin('getActivities_result')
3431 rajveer 1700
    if self.success is not None:
3131 rajveer 1701
      oprot.writeFieldBegin('success', TType.LIST, 0)
1702
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3546 mandeep.dh 1703
      for iter41 in self.success:
1704
        iter41.write(oprot)
3131 rajveer 1705
      oprot.writeListEnd()
1706
      oprot.writeFieldEnd()
1707
    oprot.writeFieldStop()
1708
    oprot.writeStructEnd()
1709
 
3431 rajveer 1710
  def validate(self):
1711
    return
1712
 
1713
 
3131 rajveer 1714
  def __repr__(self):
1715
    L = ['%s=%r' % (key, value)
1716
      for key, value in self.__dict__.iteritems()]
1717
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1718
 
1719
  def __eq__(self, other):
1720
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1721
 
1722
  def __ne__(self, other):
1723
    return not (self == other)
1724
 
3431 rajveer 1725
class insertActivity_args:
3376 rajveer 1726
  """
1727
  Attributes:
3431 rajveer 1728
   - activity
3376 rajveer 1729
  """
1730
 
1731
  thrift_spec = (
1732
    None, # 0
3431 rajveer 1733
    (1, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 1
3376 rajveer 1734
  )
1735
 
3431 rajveer 1736
  def __init__(self, activity=None,):
1737
    self.activity = activity
3376 rajveer 1738
 
1739
  def read(self, iprot):
1740
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1741
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1742
      return
1743
    iprot.readStructBegin()
1744
    while True:
1745
      (fname, ftype, fid) = iprot.readFieldBegin()
1746
      if ftype == TType.STOP:
1747
        break
1748
      if fid == 1:
3431 rajveer 1749
        if ftype == TType.STRUCT:
1750
          self.activity = Activity()
1751
          self.activity.read(iprot)
3376 rajveer 1752
        else:
1753
          iprot.skip(ftype)
1754
      else:
1755
        iprot.skip(ftype)
1756
      iprot.readFieldEnd()
1757
    iprot.readStructEnd()
1758
 
1759
  def write(self, oprot):
1760
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1761
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1762
      return
3431 rajveer 1763
    oprot.writeStructBegin('insertActivity_args')
1764
    if self.activity is not None:
1765
      oprot.writeFieldBegin('activity', TType.STRUCT, 1)
1766
      self.activity.write(oprot)
3376 rajveer 1767
      oprot.writeFieldEnd()
1768
    oprot.writeFieldStop()
1769
    oprot.writeStructEnd()
1770
 
3431 rajveer 1771
  def validate(self):
1772
    return
1773
 
1774
 
3376 rajveer 1775
  def __repr__(self):
1776
    L = ['%s=%r' % (key, value)
1777
      for key, value in self.__dict__.iteritems()]
1778
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1779
 
1780
  def __eq__(self, other):
1781
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1782
 
1783
  def __ne__(self, other):
1784
    return not (self == other)
1785
 
3431 rajveer 1786
class insertActivity_result:
3376 rajveer 1787
  """
1788
  Attributes:
1789
   - success
1790
  """
1791
 
1792
  thrift_spec = (
3431 rajveer 1793
    (0, TType.I64, 'success', None, None, ), # 0
3376 rajveer 1794
  )
1795
 
1796
  def __init__(self, success=None,):
1797
    self.success = success
1798
 
1799
  def read(self, iprot):
1800
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1801
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1802
      return
1803
    iprot.readStructBegin()
1804
    while True:
1805
      (fname, ftype, fid) = iprot.readFieldBegin()
1806
      if ftype == TType.STOP:
1807
        break
1808
      if fid == 0:
3131 rajveer 1809
        if ftype == TType.I64:
3431 rajveer 1810
          self.success = iprot.readI64();
3131 rajveer 1811
        else:
1812
          iprot.skip(ftype)
1813
      else:
1814
        iprot.skip(ftype)
1815
      iprot.readFieldEnd()
1816
    iprot.readStructEnd()
1817
 
1818
  def write(self, oprot):
1819
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1820
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1821
      return
3431 rajveer 1822
    oprot.writeStructBegin('insertActivity_result')
1823
    if self.success is not None:
1824
      oprot.writeFieldBegin('success', TType.I64, 0)
1825
      oprot.writeI64(self.success)
3131 rajveer 1826
      oprot.writeFieldEnd()
1827
    oprot.writeFieldStop()
1828
    oprot.writeStructEnd()
1829
 
3431 rajveer 1830
  def validate(self):
1831
    return
3131 rajveer 1832
 
1833
 
1834
  def __repr__(self):
1835
    L = ['%s=%r' % (key, value)
1836
      for key, value in self.__dict__.iteritems()]
1837
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1838
 
1839
  def __eq__(self, other):
1840
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1841
 
1842
  def __ne__(self, other):
1843
    return not (self == other)
1844
 
3431 rajveer 1845
class markAsRead_args:
3131 rajveer 1846
  """
1847
  Attributes:
1848
   - activityId
3431 rajveer 1849
   - agentId
3131 rajveer 1850
  """
1851
 
1852
  thrift_spec = (
1853
    None, # 0
1854
    (1, TType.I64, 'activityId', None, None, ), # 1
3431 rajveer 1855
    (2, TType.I64, 'agentId', None, None, ), # 2
3131 rajveer 1856
  )
1857
 
3431 rajveer 1858
  def __init__(self, activityId=None, agentId=None,):
3131 rajveer 1859
    self.activityId = activityId
3431 rajveer 1860
    self.agentId = agentId
3131 rajveer 1861
 
1862
  def read(self, iprot):
1863
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1864
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1865
      return
1866
    iprot.readStructBegin()
1867
    while True:
1868
      (fname, ftype, fid) = iprot.readFieldBegin()
1869
      if ftype == TType.STOP:
1870
        break
1871
      if fid == 1:
1872
        if ftype == TType.I64:
1873
          self.activityId = iprot.readI64();
1874
        else:
1875
          iprot.skip(ftype)
3431 rajveer 1876
      elif fid == 2:
1877
        if ftype == TType.I64:
1878
          self.agentId = iprot.readI64();
1879
        else:
1880
          iprot.skip(ftype)
3131 rajveer 1881
      else:
1882
        iprot.skip(ftype)
1883
      iprot.readFieldEnd()
1884
    iprot.readStructEnd()
1885
 
1886
  def write(self, oprot):
1887
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1888
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1889
      return
3431 rajveer 1890
    oprot.writeStructBegin('markAsRead_args')
1891
    if self.activityId is not None:
3131 rajveer 1892
      oprot.writeFieldBegin('activityId', TType.I64, 1)
1893
      oprot.writeI64(self.activityId)
1894
      oprot.writeFieldEnd()
3431 rajveer 1895
    if self.agentId is not None:
1896
      oprot.writeFieldBegin('agentId', TType.I64, 2)
1897
      oprot.writeI64(self.agentId)
1898
      oprot.writeFieldEnd()
3131 rajveer 1899
    oprot.writeFieldStop()
1900
    oprot.writeStructEnd()
1901
 
3431 rajveer 1902
  def validate(self):
1903
    return
3131 rajveer 1904
 
1905
 
1906
  def __repr__(self):
1907
    L = ['%s=%r' % (key, value)
1908
      for key, value in self.__dict__.iteritems()]
1909
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1910
 
1911
  def __eq__(self, other):
1912
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1913
 
1914
  def __ne__(self, other):
1915
    return not (self == other)
1916
 
3431 rajveer 1917
class markAsRead_result:
3131 rajveer 1918
 
1919
  thrift_spec = (
1920
  )
1921
 
1922
  def read(self, iprot):
1923
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1924
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1925
      return
1926
    iprot.readStructBegin()
1927
    while True:
1928
      (fname, ftype, fid) = iprot.readFieldBegin()
1929
      if ftype == TType.STOP:
1930
        break
1931
      else:
1932
        iprot.skip(ftype)
1933
      iprot.readFieldEnd()
1934
    iprot.readStructEnd()
1935
 
1936
  def write(self, oprot):
1937
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1938
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1939
      return
3431 rajveer 1940
    oprot.writeStructBegin('markAsRead_result')
3131 rajveer 1941
    oprot.writeFieldStop()
1942
    oprot.writeStructEnd()
1943
 
3431 rajveer 1944
  def validate(self):
1945
    return
3131 rajveer 1946
 
1947
 
1948
  def __repr__(self):
1949
    L = ['%s=%r' % (key, value)
1950
      for key, value in self.__dict__.iteritems()]
1951
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1952
 
1953
  def __eq__(self, other):
1954
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1955
 
1956
  def __ne__(self, other):
1957
    return not (self == other)
1958
 
3431 rajveer 1959
class getAgents_args:
3131 rajveer 1960
  """
1961
  Attributes:
3431 rajveer 1962
   - searchFilter
3131 rajveer 1963
  """
1964
 
1965
  thrift_spec = (
1966
    None, # 0
3431 rajveer 1967
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 1968
  )
1969
 
3431 rajveer 1970
  def __init__(self, searchFilter=None,):
1971
    self.searchFilter = searchFilter
3131 rajveer 1972
 
1973
  def read(self, iprot):
1974
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1975
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1976
      return
1977
    iprot.readStructBegin()
1978
    while True:
1979
      (fname, ftype, fid) = iprot.readFieldBegin()
1980
      if ftype == TType.STOP:
1981
        break
1982
      if fid == 1:
1983
        if ftype == TType.STRUCT:
3431 rajveer 1984
          self.searchFilter = SearchFilter()
1985
          self.searchFilter.read(iprot)
3131 rajveer 1986
        else:
1987
          iprot.skip(ftype)
1988
      else:
1989
        iprot.skip(ftype)
1990
      iprot.readFieldEnd()
1991
    iprot.readStructEnd()
1992
 
1993
  def write(self, oprot):
1994
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1995
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1996
      return
3431 rajveer 1997
    oprot.writeStructBegin('getAgents_args')
1998
    if self.searchFilter is not None:
1999
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
2000
      self.searchFilter.write(oprot)
3131 rajveer 2001
      oprot.writeFieldEnd()
2002
    oprot.writeFieldStop()
2003
    oprot.writeStructEnd()
2004
 
3431 rajveer 2005
  def validate(self):
2006
    return
3131 rajveer 2007
 
2008
 
2009
  def __repr__(self):
2010
    L = ['%s=%r' % (key, value)
2011
      for key, value in self.__dict__.iteritems()]
2012
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2013
 
2014
  def __eq__(self, other):
2015
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2016
 
2017
  def __ne__(self, other):
2018
    return not (self == other)
2019
 
3431 rajveer 2020
class getAgents_result:
3131 rajveer 2021
  """
2022
  Attributes:
2023
   - success
2024
  """
2025
 
2026
  thrift_spec = (
2027
    (0, TType.LIST, 'success', (TType.STRUCT,(Agent, Agent.thrift_spec)), None, ), # 0
2028
  )
2029
 
2030
  def __init__(self, success=None,):
2031
    self.success = success
2032
 
2033
  def read(self, iprot):
2034
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2035
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2036
      return
2037
    iprot.readStructBegin()
2038
    while True:
2039
      (fname, ftype, fid) = iprot.readFieldBegin()
2040
      if ftype == TType.STOP:
2041
        break
2042
      if fid == 0:
2043
        if ftype == TType.LIST:
2044
          self.success = []
3546 mandeep.dh 2045
          (_etype45, _size42) = iprot.readListBegin()
2046
          for _i46 in xrange(_size42):
2047
            _elem47 = Agent()
2048
            _elem47.read(iprot)
2049
            self.success.append(_elem47)
3131 rajveer 2050
          iprot.readListEnd()
2051
        else:
2052
          iprot.skip(ftype)
2053
      else:
2054
        iprot.skip(ftype)
2055
      iprot.readFieldEnd()
2056
    iprot.readStructEnd()
2057
 
2058
  def write(self, oprot):
2059
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2060
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2061
      return
3431 rajveer 2062
    oprot.writeStructBegin('getAgents_result')
2063
    if self.success is not None:
3131 rajveer 2064
      oprot.writeFieldBegin('success', TType.LIST, 0)
2065
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3546 mandeep.dh 2066
      for iter48 in self.success:
2067
        iter48.write(oprot)
3131 rajveer 2068
      oprot.writeListEnd()
2069
      oprot.writeFieldEnd()
2070
    oprot.writeFieldStop()
2071
    oprot.writeStructEnd()
2072
 
3431 rajveer 2073
  def validate(self):
2074
    return
3131 rajveer 2075
 
2076
 
2077
  def __repr__(self):
2078
    L = ['%s=%r' % (key, value)
2079
      for key, value in self.__dict__.iteritems()]
2080
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2081
 
2082
  def __eq__(self, other):
2083
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2084
 
2085
  def __ne__(self, other):
2086
    return not (self == other)
2087
 
5407 amar.kumar 2088
class getInactiveAgents_args:
2089
  """
2090
  Attributes:
2091
   - searchFilter
2092
  """
2093
 
2094
  thrift_spec = (
2095
    None, # 0
2096
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
2097
  )
2098
 
2099
  def __init__(self, searchFilter=None,):
2100
    self.searchFilter = searchFilter
2101
 
2102
  def read(self, iprot):
2103
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2104
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2105
      return
2106
    iprot.readStructBegin()
2107
    while True:
2108
      (fname, ftype, fid) = iprot.readFieldBegin()
2109
      if ftype == TType.STOP:
2110
        break
2111
      if fid == 1:
2112
        if ftype == TType.STRUCT:
2113
          self.searchFilter = SearchFilter()
2114
          self.searchFilter.read(iprot)
2115
        else:
2116
          iprot.skip(ftype)
2117
      else:
2118
        iprot.skip(ftype)
2119
      iprot.readFieldEnd()
2120
    iprot.readStructEnd()
2121
 
2122
  def write(self, oprot):
2123
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2124
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2125
      return
2126
    oprot.writeStructBegin('getInactiveAgents_args')
2127
    if self.searchFilter is not None:
2128
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
2129
      self.searchFilter.write(oprot)
2130
      oprot.writeFieldEnd()
2131
    oprot.writeFieldStop()
2132
    oprot.writeStructEnd()
2133
 
2134
  def validate(self):
2135
    return
2136
 
2137
 
2138
  def __repr__(self):
2139
    L = ['%s=%r' % (key, value)
2140
      for key, value in self.__dict__.iteritems()]
2141
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2142
 
2143
  def __eq__(self, other):
2144
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2145
 
2146
  def __ne__(self, other):
2147
    return not (self == other)
2148
 
2149
class getInactiveAgents_result:
2150
  """
2151
  Attributes:
2152
   - success
2153
  """
2154
 
2155
  thrift_spec = (
2156
    (0, TType.LIST, 'success', (TType.STRUCT,(Agent, Agent.thrift_spec)), None, ), # 0
2157
  )
2158
 
2159
  def __init__(self, success=None,):
2160
    self.success = success
2161
 
2162
  def read(self, iprot):
2163
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2164
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2165
      return
2166
    iprot.readStructBegin()
2167
    while True:
2168
      (fname, ftype, fid) = iprot.readFieldBegin()
2169
      if ftype == TType.STOP:
2170
        break
2171
      if fid == 0:
2172
        if ftype == TType.LIST:
2173
          self.success = []
2174
          (_etype52, _size49) = iprot.readListBegin()
2175
          for _i53 in xrange(_size49):
2176
            _elem54 = Agent()
2177
            _elem54.read(iprot)
2178
            self.success.append(_elem54)
2179
          iprot.readListEnd()
2180
        else:
2181
          iprot.skip(ftype)
2182
      else:
2183
        iprot.skip(ftype)
2184
      iprot.readFieldEnd()
2185
    iprot.readStructEnd()
2186
 
2187
  def write(self, oprot):
2188
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2189
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2190
      return
2191
    oprot.writeStructBegin('getInactiveAgents_result')
2192
    if self.success is not None:
2193
      oprot.writeFieldBegin('success', TType.LIST, 0)
2194
      oprot.writeListBegin(TType.STRUCT, len(self.success))
2195
      for iter55 in self.success:
2196
        iter55.write(oprot)
2197
      oprot.writeListEnd()
2198
      oprot.writeFieldEnd()
2199
    oprot.writeFieldStop()
2200
    oprot.writeStructEnd()
2201
 
2202
  def validate(self):
2203
    return
2204
 
2205
 
2206
  def __repr__(self):
2207
    L = ['%s=%r' % (key, value)
2208
      for key, value in self.__dict__.iteritems()]
2209
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2210
 
2211
  def __eq__(self, other):
2212
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2213
 
2214
  def __ne__(self, other):
2215
    return not (self == other)
2216
 
3131 rajveer 2217
class updatePasswordForAgent_args:
2218
  """
2219
  Attributes:
2220
   - agentEmailId
2221
   - password
2222
  """
2223
 
2224
  thrift_spec = (
2225
    None, # 0
2226
    (1, TType.STRING, 'agentEmailId', None, None, ), # 1
2227
    (2, TType.STRING, 'password', None, None, ), # 2
2228
  )
2229
 
2230
  def __init__(self, agentEmailId=None, password=None,):
2231
    self.agentEmailId = agentEmailId
2232
    self.password = password
2233
 
2234
  def read(self, iprot):
2235
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2236
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2237
      return
2238
    iprot.readStructBegin()
2239
    while True:
2240
      (fname, ftype, fid) = iprot.readFieldBegin()
2241
      if ftype == TType.STOP:
2242
        break
2243
      if fid == 1:
2244
        if ftype == TType.STRING:
2245
          self.agentEmailId = iprot.readString();
2246
        else:
2247
          iprot.skip(ftype)
2248
      elif fid == 2:
2249
        if ftype == TType.STRING:
2250
          self.password = iprot.readString();
2251
        else:
2252
          iprot.skip(ftype)
2253
      else:
2254
        iprot.skip(ftype)
2255
      iprot.readFieldEnd()
2256
    iprot.readStructEnd()
2257
 
2258
  def write(self, oprot):
2259
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2260
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2261
      return
2262
    oprot.writeStructBegin('updatePasswordForAgent_args')
3431 rajveer 2263
    if self.agentEmailId is not None:
3131 rajveer 2264
      oprot.writeFieldBegin('agentEmailId', TType.STRING, 1)
2265
      oprot.writeString(self.agentEmailId)
2266
      oprot.writeFieldEnd()
3431 rajveer 2267
    if self.password is not None:
3131 rajveer 2268
      oprot.writeFieldBegin('password', TType.STRING, 2)
2269
      oprot.writeString(self.password)
2270
      oprot.writeFieldEnd()
2271
    oprot.writeFieldStop()
2272
    oprot.writeStructEnd()
2273
 
3431 rajveer 2274
  def validate(self):
2275
    return
2276
 
2277
 
3131 rajveer 2278
  def __repr__(self):
2279
    L = ['%s=%r' % (key, value)
2280
      for key, value in self.__dict__.iteritems()]
2281
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2282
 
2283
  def __eq__(self, other):
2284
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2285
 
2286
  def __ne__(self, other):
2287
    return not (self == other)
2288
 
2289
class updatePasswordForAgent_result:
2290
 
2291
  thrift_spec = (
2292
  )
2293
 
2294
  def read(self, iprot):
2295
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2296
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2297
      return
2298
    iprot.readStructBegin()
2299
    while True:
2300
      (fname, ftype, fid) = iprot.readFieldBegin()
2301
      if ftype == TType.STOP:
2302
        break
2303
      else:
2304
        iprot.skip(ftype)
2305
      iprot.readFieldEnd()
2306
    iprot.readStructEnd()
2307
 
2308
  def write(self, oprot):
2309
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2310
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2311
      return
2312
    oprot.writeStructBegin('updatePasswordForAgent_result')
2313
    oprot.writeFieldStop()
2314
    oprot.writeStructEnd()
2315
 
3431 rajveer 2316
  def validate(self):
2317
    return
2318
 
2319
 
3131 rajveer 2320
  def __repr__(self):
2321
    L = ['%s=%r' % (key, value)
2322
      for key, value in self.__dict__.iteritems()]
2323
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2324
 
2325
  def __eq__(self, other):
2326
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2327
 
2328
  def __ne__(self, other):
2329
    return not (self == other)
2330
 
2331
class getRoleNamesForAgent_args:
2332
  """
2333
  Attributes:
2334
   - agentEmailId
2335
  """
2336
 
2337
  thrift_spec = (
2338
    None, # 0
2339
    (1, TType.STRING, 'agentEmailId', None, None, ), # 1
2340
  )
2341
 
2342
  def __init__(self, agentEmailId=None,):
2343
    self.agentEmailId = agentEmailId
2344
 
2345
  def read(self, iprot):
2346
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2347
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2348
      return
2349
    iprot.readStructBegin()
2350
    while True:
2351
      (fname, ftype, fid) = iprot.readFieldBegin()
2352
      if ftype == TType.STOP:
2353
        break
2354
      if fid == 1:
2355
        if ftype == TType.STRING:
2356
          self.agentEmailId = iprot.readString();
2357
        else:
2358
          iprot.skip(ftype)
2359
      else:
2360
        iprot.skip(ftype)
2361
      iprot.readFieldEnd()
2362
    iprot.readStructEnd()
2363
 
2364
  def write(self, oprot):
2365
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2366
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2367
      return
2368
    oprot.writeStructBegin('getRoleNamesForAgent_args')
3431 rajveer 2369
    if self.agentEmailId is not None:
3131 rajveer 2370
      oprot.writeFieldBegin('agentEmailId', TType.STRING, 1)
2371
      oprot.writeString(self.agentEmailId)
2372
      oprot.writeFieldEnd()
2373
    oprot.writeFieldStop()
2374
    oprot.writeStructEnd()
2375
 
3431 rajveer 2376
  def validate(self):
2377
    return
2378
 
2379
 
3131 rajveer 2380
  def __repr__(self):
2381
    L = ['%s=%r' % (key, value)
2382
      for key, value in self.__dict__.iteritems()]
2383
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2384
 
2385
  def __eq__(self, other):
2386
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2387
 
2388
  def __ne__(self, other):
2389
    return not (self == other)
2390
 
2391
class getRoleNamesForAgent_result:
2392
  """
2393
  Attributes:
2394
   - success
2395
  """
2396
 
2397
  thrift_spec = (
2398
    (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
2399
  )
2400
 
2401
  def __init__(self, success=None,):
2402
    self.success = success
2403
 
2404
  def read(self, iprot):
2405
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2406
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2407
      return
2408
    iprot.readStructBegin()
2409
    while True:
2410
      (fname, ftype, fid) = iprot.readFieldBegin()
2411
      if ftype == TType.STOP:
2412
        break
2413
      if fid == 0:
2414
        if ftype == TType.LIST:
2415
          self.success = []
5407 amar.kumar 2416
          (_etype59, _size56) = iprot.readListBegin()
2417
          for _i60 in xrange(_size56):
2418
            _elem61 = iprot.readString();
2419
            self.success.append(_elem61)
3131 rajveer 2420
          iprot.readListEnd()
2421
        else:
2422
          iprot.skip(ftype)
2423
      else:
2424
        iprot.skip(ftype)
2425
      iprot.readFieldEnd()
2426
    iprot.readStructEnd()
2427
 
2428
  def write(self, oprot):
2429
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2430
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2431
      return
2432
    oprot.writeStructBegin('getRoleNamesForAgent_result')
3431 rajveer 2433
    if self.success is not None:
3131 rajveer 2434
      oprot.writeFieldBegin('success', TType.LIST, 0)
2435
      oprot.writeListBegin(TType.STRING, len(self.success))
5407 amar.kumar 2436
      for iter62 in self.success:
2437
        oprot.writeString(iter62)
3131 rajveer 2438
      oprot.writeListEnd()
2439
      oprot.writeFieldEnd()
2440
    oprot.writeFieldStop()
2441
    oprot.writeStructEnd()
2442
 
3431 rajveer 2443
  def validate(self):
2444
    return
2445
 
2446
 
3131 rajveer 2447
  def __repr__(self):
2448
    L = ['%s=%r' % (key, value)
2449
      for key, value in self.__dict__.iteritems()]
2450
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2451
 
2452
  def __eq__(self, other):
2453
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2454
 
2455
  def __ne__(self, other):
2456
    return not (self == other)
2457
 
2458
class getPermissionsForRoleName_args:
2459
  """
2460
  Attributes:
2461
   - roleName
2462
  """
2463
 
2464
  thrift_spec = (
2465
    None, # 0
2466
    (1, TType.STRING, 'roleName', None, None, ), # 1
2467
  )
2468
 
2469
  def __init__(self, roleName=None,):
2470
    self.roleName = roleName
2471
 
2472
  def read(self, iprot):
2473
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2474
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2475
      return
2476
    iprot.readStructBegin()
2477
    while True:
2478
      (fname, ftype, fid) = iprot.readFieldBegin()
2479
      if ftype == TType.STOP:
2480
        break
2481
      if fid == 1:
2482
        if ftype == TType.STRING:
2483
          self.roleName = iprot.readString();
2484
        else:
2485
          iprot.skip(ftype)
2486
      else:
2487
        iprot.skip(ftype)
2488
      iprot.readFieldEnd()
2489
    iprot.readStructEnd()
2490
 
2491
  def write(self, oprot):
2492
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2493
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2494
      return
2495
    oprot.writeStructBegin('getPermissionsForRoleName_args')
3431 rajveer 2496
    if self.roleName is not None:
3131 rajveer 2497
      oprot.writeFieldBegin('roleName', TType.STRING, 1)
2498
      oprot.writeString(self.roleName)
2499
      oprot.writeFieldEnd()
2500
    oprot.writeFieldStop()
2501
    oprot.writeStructEnd()
2502
 
3431 rajveer 2503
  def validate(self):
2504
    return
2505
 
2506
 
3131 rajveer 2507
  def __repr__(self):
2508
    L = ['%s=%r' % (key, value)
2509
      for key, value in self.__dict__.iteritems()]
2510
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2511
 
2512
  def __eq__(self, other):
2513
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2514
 
2515
  def __ne__(self, other):
2516
    return not (self == other)
2517
 
2518
class getPermissionsForRoleName_result:
2519
  """
2520
  Attributes:
2521
   - success
2522
  """
2523
 
2524
  thrift_spec = (
2525
    (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
2526
  )
2527
 
2528
  def __init__(self, success=None,):
2529
    self.success = success
2530
 
2531
  def read(self, iprot):
2532
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2533
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2534
      return
2535
    iprot.readStructBegin()
2536
    while True:
2537
      (fname, ftype, fid) = iprot.readFieldBegin()
2538
      if ftype == TType.STOP:
2539
        break
2540
      if fid == 0:
2541
        if ftype == TType.LIST:
2542
          self.success = []
5407 amar.kumar 2543
          (_etype66, _size63) = iprot.readListBegin()
2544
          for _i67 in xrange(_size63):
2545
            _elem68 = iprot.readString();
2546
            self.success.append(_elem68)
3131 rajveer 2547
          iprot.readListEnd()
2548
        else:
2549
          iprot.skip(ftype)
2550
      else:
2551
        iprot.skip(ftype)
2552
      iprot.readFieldEnd()
2553
    iprot.readStructEnd()
2554
 
2555
  def write(self, oprot):
2556
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2557
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2558
      return
2559
    oprot.writeStructBegin('getPermissionsForRoleName_result')
3431 rajveer 2560
    if self.success is not None:
3131 rajveer 2561
      oprot.writeFieldBegin('success', TType.LIST, 0)
2562
      oprot.writeListBegin(TType.STRING, len(self.success))
5407 amar.kumar 2563
      for iter69 in self.success:
2564
        oprot.writeString(iter69)
3131 rajveer 2565
      oprot.writeListEnd()
2566
      oprot.writeFieldEnd()
2567
    oprot.writeFieldStop()
2568
    oprot.writeStructEnd()
2569
 
3431 rajveer 2570
  def validate(self):
2571
    return
2572
 
2573
 
3131 rajveer 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
 
3376 rajveer 2585
class getLastEmailProcessedTimestamp_args:
3131 rajveer 2586
 
3376 rajveer 2587
  thrift_spec = (
2588
  )
2589
 
2590
  def read(self, iprot):
2591
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2592
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2593
      return
2594
    iprot.readStructBegin()
2595
    while True:
2596
      (fname, ftype, fid) = iprot.readFieldBegin()
2597
      if ftype == TType.STOP:
2598
        break
2599
      else:
2600
        iprot.skip(ftype)
2601
      iprot.readFieldEnd()
2602
    iprot.readStructEnd()
2603
 
2604
  def write(self, oprot):
2605
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2606
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2607
      return
2608
    oprot.writeStructBegin('getLastEmailProcessedTimestamp_args')
2609
    oprot.writeFieldStop()
2610
    oprot.writeStructEnd()
2611
 
3431 rajveer 2612
  def validate(self):
2613
    return
2614
 
2615
 
3376 rajveer 2616
  def __repr__(self):
2617
    L = ['%s=%r' % (key, value)
2618
      for key, value in self.__dict__.iteritems()]
2619
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2620
 
2621
  def __eq__(self, other):
2622
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2623
 
2624
  def __ne__(self, other):
2625
    return not (self == other)
2626
 
2627
class getLastEmailProcessedTimestamp_result:
2628
  """
2629
  Attributes:
2630
   - success
2631
  """
2632
 
2633
  thrift_spec = (
2634
    (0, TType.I64, 'success', None, None, ), # 0
2635
  )
2636
 
2637
  def __init__(self, success=None,):
2638
    self.success = success
2639
 
2640
  def read(self, iprot):
2641
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2642
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2643
      return
2644
    iprot.readStructBegin()
2645
    while True:
2646
      (fname, ftype, fid) = iprot.readFieldBegin()
2647
      if ftype == TType.STOP:
2648
        break
2649
      if fid == 0:
2650
        if ftype == TType.I64:
2651
          self.success = iprot.readI64();
2652
        else:
2653
          iprot.skip(ftype)
2654
      else:
2655
        iprot.skip(ftype)
2656
      iprot.readFieldEnd()
2657
    iprot.readStructEnd()
2658
 
2659
  def write(self, oprot):
2660
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2661
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2662
      return
2663
    oprot.writeStructBegin('getLastEmailProcessedTimestamp_result')
3431 rajveer 2664
    if self.success is not None:
3376 rajveer 2665
      oprot.writeFieldBegin('success', TType.I64, 0)
2666
      oprot.writeI64(self.success)
2667
      oprot.writeFieldEnd()
2668
    oprot.writeFieldStop()
2669
    oprot.writeStructEnd()
2670
 
3431 rajveer 2671
  def validate(self):
2672
    return
2673
 
2674
 
3376 rajveer 2675
  def __repr__(self):
2676
    L = ['%s=%r' % (key, value)
2677
      for key, value in self.__dict__.iteritems()]
2678
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2679
 
2680
  def __eq__(self, other):
2681
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2682
 
2683
  def __ne__(self, other):
2684
    return not (self == other)
2685
 
2686
class updateLastEmailProcessedTimestamp_args:
2687
  """
2688
  Attributes:
2689
   - timestamp
2690
  """
2691
 
2692
  thrift_spec = (
2693
    None, # 0
2694
    (1, TType.I64, 'timestamp', None, None, ), # 1
2695
  )
2696
 
2697
  def __init__(self, timestamp=None,):
2698
    self.timestamp = timestamp
2699
 
2700
  def read(self, iprot):
2701
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2702
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2703
      return
2704
    iprot.readStructBegin()
2705
    while True:
2706
      (fname, ftype, fid) = iprot.readFieldBegin()
2707
      if ftype == TType.STOP:
2708
        break
2709
      if fid == 1:
2710
        if ftype == TType.I64:
2711
          self.timestamp = iprot.readI64();
2712
        else:
2713
          iprot.skip(ftype)
2714
      else:
2715
        iprot.skip(ftype)
2716
      iprot.readFieldEnd()
2717
    iprot.readStructEnd()
2718
 
2719
  def write(self, oprot):
2720
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2721
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2722
      return
2723
    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_args')
3431 rajveer 2724
    if self.timestamp is not None:
3376 rajveer 2725
      oprot.writeFieldBegin('timestamp', TType.I64, 1)
2726
      oprot.writeI64(self.timestamp)
2727
      oprot.writeFieldEnd()
2728
    oprot.writeFieldStop()
2729
    oprot.writeStructEnd()
2730
 
3431 rajveer 2731
  def validate(self):
2732
    return
2733
 
2734
 
3376 rajveer 2735
  def __repr__(self):
2736
    L = ['%s=%r' % (key, value)
2737
      for key, value in self.__dict__.iteritems()]
2738
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2739
 
2740
  def __eq__(self, other):
2741
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2742
 
2743
  def __ne__(self, other):
2744
    return not (self == other)
2745
 
2746
class updateLastEmailProcessedTimestamp_result:
2747
 
2748
  thrift_spec = (
2749
  )
2750
 
2751
  def read(self, iprot):
2752
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2753
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2754
      return
2755
    iprot.readStructBegin()
2756
    while True:
2757
      (fname, ftype, fid) = iprot.readFieldBegin()
2758
      if ftype == TType.STOP:
2759
        break
2760
      else:
2761
        iprot.skip(ftype)
2762
      iprot.readFieldEnd()
2763
    iprot.readStructEnd()
2764
 
2765
  def write(self, oprot):
2766
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2767
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2768
      return
2769
    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_result')
2770
    oprot.writeFieldStop()
2771
    oprot.writeStructEnd()
2772
 
3431 rajveer 2773
  def validate(self):
2774
    return
2775
 
2776
 
3376 rajveer 2777
  def __repr__(self):
2778
    L = ['%s=%r' % (key, value)
2779
      for key, value in self.__dict__.iteritems()]
2780
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2781
 
2782
  def __eq__(self, other):
2783
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2784
 
2785
  def __ne__(self, other):
2786
    return not (self == other)
4948 phani.kuma 2787
 
2788
class changeAgentStatus_args:
2789
  """
2790
  Attributes:
2791
   - status
2792
   - emailId
2793
  """
2794
 
2795
  thrift_spec = (
2796
    None, # 0
2797
    (1, TType.BOOL, 'status', None, None, ), # 1
2798
    (2, TType.STRING, 'emailId', None, None, ), # 2
2799
  )
2800
 
2801
  def __init__(self, status=None, emailId=None,):
2802
    self.status = status
2803
    self.emailId = emailId
2804
 
2805
  def read(self, iprot):
2806
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2807
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2808
      return
2809
    iprot.readStructBegin()
2810
    while True:
2811
      (fname, ftype, fid) = iprot.readFieldBegin()
2812
      if ftype == TType.STOP:
2813
        break
2814
      if fid == 1:
2815
        if ftype == TType.BOOL:
2816
          self.status = iprot.readBool();
2817
        else:
2818
          iprot.skip(ftype)
2819
      elif fid == 2:
2820
        if ftype == TType.STRING:
2821
          self.emailId = iprot.readString();
2822
        else:
2823
          iprot.skip(ftype)
2824
      else:
2825
        iprot.skip(ftype)
2826
      iprot.readFieldEnd()
2827
    iprot.readStructEnd()
2828
 
2829
  def write(self, oprot):
2830
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2831
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2832
      return
2833
    oprot.writeStructBegin('changeAgentStatus_args')
2834
    if self.status is not None:
2835
      oprot.writeFieldBegin('status', TType.BOOL, 1)
2836
      oprot.writeBool(self.status)
2837
      oprot.writeFieldEnd()
2838
    if self.emailId is not None:
2839
      oprot.writeFieldBegin('emailId', TType.STRING, 2)
2840
      oprot.writeString(self.emailId)
2841
      oprot.writeFieldEnd()
2842
    oprot.writeFieldStop()
2843
    oprot.writeStructEnd()
2844
 
2845
  def validate(self):
2846
    return
2847
 
2848
 
2849
  def __repr__(self):
2850
    L = ['%s=%r' % (key, value)
2851
      for key, value in self.__dict__.iteritems()]
2852
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2853
 
2854
  def __eq__(self, other):
2855
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2856
 
2857
  def __ne__(self, other):
2858
    return not (self == other)
2859
 
2860
class changeAgentStatus_result:
2861
 
2862
  thrift_spec = (
2863
  )
2864
 
2865
  def read(self, iprot):
2866
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2867
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2868
      return
2869
    iprot.readStructBegin()
2870
    while True:
2871
      (fname, ftype, fid) = iprot.readFieldBegin()
2872
      if ftype == TType.STOP:
2873
        break
2874
      else:
2875
        iprot.skip(ftype)
2876
      iprot.readFieldEnd()
2877
    iprot.readStructEnd()
2878
 
2879
  def write(self, oprot):
2880
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2881
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2882
      return
2883
    oprot.writeStructBegin('changeAgentStatus_result')
2884
    oprot.writeFieldStop()
2885
    oprot.writeStructEnd()
2886
 
2887
  def validate(self):
2888
    return
2889
 
2890
 
2891
  def __repr__(self):
2892
    L = ['%s=%r' % (key, value)
2893
      for key, value in self.__dict__.iteritems()]
2894
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2895
 
2896
  def __eq__(self, other):
2897
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2898
 
2899
  def __ne__(self, other):
2900
    return not (self == other)
2901
 
2902
class insertAgent_args:
2903
  """
2904
  Attributes:
2905
   - agent
2906
   - role
2907
  """
2908
 
2909
  thrift_spec = (
2910
    None, # 0
2911
    (1, TType.STRUCT, 'agent', (Agent, Agent.thrift_spec), None, ), # 1
2912
    (2, TType.LIST, 'role', (TType.STRING,None), None, ), # 2
2913
  )
2914
 
2915
  def __init__(self, agent=None, role=None,):
2916
    self.agent = agent
2917
    self.role = role
2918
 
2919
  def read(self, iprot):
2920
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2921
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2922
      return
2923
    iprot.readStructBegin()
2924
    while True:
2925
      (fname, ftype, fid) = iprot.readFieldBegin()
2926
      if ftype == TType.STOP:
2927
        break
2928
      if fid == 1:
2929
        if ftype == TType.STRUCT:
2930
          self.agent = Agent()
2931
          self.agent.read(iprot)
2932
        else:
2933
          iprot.skip(ftype)
2934
      elif fid == 2:
2935
        if ftype == TType.LIST:
2936
          self.role = []
5407 amar.kumar 2937
          (_etype73, _size70) = iprot.readListBegin()
2938
          for _i74 in xrange(_size70):
2939
            _elem75 = iprot.readString();
2940
            self.role.append(_elem75)
4948 phani.kuma 2941
          iprot.readListEnd()
2942
        else:
2943
          iprot.skip(ftype)
2944
      else:
2945
        iprot.skip(ftype)
2946
      iprot.readFieldEnd()
2947
    iprot.readStructEnd()
2948
 
2949
  def write(self, oprot):
2950
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2951
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2952
      return
2953
    oprot.writeStructBegin('insertAgent_args')
2954
    if self.agent is not None:
2955
      oprot.writeFieldBegin('agent', TType.STRUCT, 1)
2956
      self.agent.write(oprot)
2957
      oprot.writeFieldEnd()
2958
    if self.role is not None:
2959
      oprot.writeFieldBegin('role', TType.LIST, 2)
2960
      oprot.writeListBegin(TType.STRING, len(self.role))
5407 amar.kumar 2961
      for iter76 in self.role:
2962
        oprot.writeString(iter76)
4948 phani.kuma 2963
      oprot.writeListEnd()
2964
      oprot.writeFieldEnd()
2965
    oprot.writeFieldStop()
2966
    oprot.writeStructEnd()
2967
 
2968
  def validate(self):
2969
    return
2970
 
2971
 
2972
  def __repr__(self):
2973
    L = ['%s=%r' % (key, value)
2974
      for key, value in self.__dict__.iteritems()]
2975
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2976
 
2977
  def __eq__(self, other):
2978
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2979
 
2980
  def __ne__(self, other):
2981
    return not (self == other)
2982
 
2983
class insertAgent_result:
2984
 
2985
  thrift_spec = (
2986
  )
2987
 
2988
  def read(self, iprot):
2989
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2990
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2991
      return
2992
    iprot.readStructBegin()
2993
    while True:
2994
      (fname, ftype, fid) = iprot.readFieldBegin()
2995
      if ftype == TType.STOP:
2996
        break
2997
      else:
2998
        iprot.skip(ftype)
2999
      iprot.readFieldEnd()
3000
    iprot.readStructEnd()
3001
 
3002
  def write(self, oprot):
3003
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3004
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3005
      return
3006
    oprot.writeStructBegin('insertAgent_result')
3007
    oprot.writeFieldStop()
3008
    oprot.writeStructEnd()
3009
 
3010
  def validate(self):
3011
    return
3012
 
3013
 
3014
  def __repr__(self):
3015
    L = ['%s=%r' % (key, value)
3016
      for key, value in self.__dict__.iteritems()]
3017
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3018
 
3019
  def __eq__(self, other):
3020
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3021
 
3022
  def __ne__(self, other):
3023
    return not (self == other)
5407 amar.kumar 3024
 
3025
class changeAgentRole_args:
3026
  """
3027
  Attributes:
3028
   - id
3029
   - role
3030
  """
3031
 
3032
  thrift_spec = (
3033
    None, # 0
3034
    (1, TType.I64, 'id', None, None, ), # 1
3035
    (2, TType.LIST, 'role', (TType.STRING,None), None, ), # 2
3036
  )
3037
 
3038
  def __init__(self, id=None, role=None,):
3039
    self.id = id
3040
    self.role = role
3041
 
3042
  def read(self, iprot):
3043
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3044
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3045
      return
3046
    iprot.readStructBegin()
3047
    while True:
3048
      (fname, ftype, fid) = iprot.readFieldBegin()
3049
      if ftype == TType.STOP:
3050
        break
3051
      if fid == 1:
3052
        if ftype == TType.I64:
3053
          self.id = iprot.readI64();
3054
        else:
3055
          iprot.skip(ftype)
3056
      elif fid == 2:
3057
        if ftype == TType.LIST:
3058
          self.role = []
3059
          (_etype80, _size77) = iprot.readListBegin()
3060
          for _i81 in xrange(_size77):
3061
            _elem82 = iprot.readString();
3062
            self.role.append(_elem82)
3063
          iprot.readListEnd()
3064
        else:
3065
          iprot.skip(ftype)
3066
      else:
3067
        iprot.skip(ftype)
3068
      iprot.readFieldEnd()
3069
    iprot.readStructEnd()
3070
 
3071
  def write(self, oprot):
3072
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3073
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3074
      return
3075
    oprot.writeStructBegin('changeAgentRole_args')
3076
    if self.id is not None:
3077
      oprot.writeFieldBegin('id', TType.I64, 1)
3078
      oprot.writeI64(self.id)
3079
      oprot.writeFieldEnd()
3080
    if self.role is not None:
3081
      oprot.writeFieldBegin('role', TType.LIST, 2)
3082
      oprot.writeListBegin(TType.STRING, len(self.role))
3083
      for iter83 in self.role:
3084
        oprot.writeString(iter83)
3085
      oprot.writeListEnd()
3086
      oprot.writeFieldEnd()
3087
    oprot.writeFieldStop()
3088
    oprot.writeStructEnd()
3089
 
3090
  def validate(self):
3091
    return
3092
 
3093
 
3094
  def __repr__(self):
3095
    L = ['%s=%r' % (key, value)
3096
      for key, value in self.__dict__.iteritems()]
3097
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3098
 
3099
  def __eq__(self, other):
3100
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3101
 
3102
  def __ne__(self, other):
3103
    return not (self == other)
3104
 
3105
class changeAgentRole_result:
3106
 
3107
  thrift_spec = (
3108
  )
3109
 
3110
  def read(self, iprot):
3111
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3112
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3113
      return
3114
    iprot.readStructBegin()
3115
    while True:
3116
      (fname, ftype, fid) = iprot.readFieldBegin()
3117
      if ftype == TType.STOP:
3118
        break
3119
      else:
3120
        iprot.skip(ftype)
3121
      iprot.readFieldEnd()
3122
    iprot.readStructEnd()
3123
 
3124
  def write(self, oprot):
3125
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3126
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3127
      return
3128
    oprot.writeStructBegin('changeAgentRole_result')
3129
    oprot.writeFieldStop()
3130
    oprot.writeStructEnd()
3131
 
3132
  def validate(self):
3133
    return
3134
 
3135
 
3136
  def __repr__(self):
3137
    L = ['%s=%r' % (key, value)
3138
      for key, value in self.__dict__.iteritems()]
3139
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3140
 
3141
  def __eq__(self, other):
3142
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3143
 
3144
  def __ne__(self, other):
3145
    return not (self == other)
3146
 
3147
class getOpenTicketCountForAgent_args:
3148
  """
3149
  Attributes:
3150
   - agentId
3151
  """
3152
 
3153
  thrift_spec = (
3154
    None, # 0
3155
    (1, TType.I64, 'agentId', None, None, ), # 1
3156
  )
3157
 
3158
  def __init__(self, agentId=None,):
3159
    self.agentId = agentId
3160
 
3161
  def read(self, iprot):
3162
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3163
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3164
      return
3165
    iprot.readStructBegin()
3166
    while True:
3167
      (fname, ftype, fid) = iprot.readFieldBegin()
3168
      if ftype == TType.STOP:
3169
        break
3170
      if fid == 1:
3171
        if ftype == TType.I64:
3172
          self.agentId = iprot.readI64();
3173
        else:
3174
          iprot.skip(ftype)
3175
      else:
3176
        iprot.skip(ftype)
3177
      iprot.readFieldEnd()
3178
    iprot.readStructEnd()
3179
 
3180
  def write(self, oprot):
3181
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3182
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3183
      return
3184
    oprot.writeStructBegin('getOpenTicketCountForAgent_args')
3185
    if self.agentId is not None:
3186
      oprot.writeFieldBegin('agentId', TType.I64, 1)
3187
      oprot.writeI64(self.agentId)
3188
      oprot.writeFieldEnd()
3189
    oprot.writeFieldStop()
3190
    oprot.writeStructEnd()
3191
 
3192
  def validate(self):
3193
    return
3194
 
3195
 
3196
  def __repr__(self):
3197
    L = ['%s=%r' % (key, value)
3198
      for key, value in self.__dict__.iteritems()]
3199
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3200
 
3201
  def __eq__(self, other):
3202
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3203
 
3204
  def __ne__(self, other):
3205
    return not (self == other)
3206
 
3207
class getOpenTicketCountForAgent_result:
3208
  """
3209
  Attributes:
3210
   - success
3211
  """
3212
 
3213
  thrift_spec = (
3214
    (0, TType.I32, 'success', None, None, ), # 0
3215
  )
3216
 
3217
  def __init__(self, success=None,):
3218
    self.success = success
3219
 
3220
  def read(self, iprot):
3221
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3222
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3223
      return
3224
    iprot.readStructBegin()
3225
    while True:
3226
      (fname, ftype, fid) = iprot.readFieldBegin()
3227
      if ftype == TType.STOP:
3228
        break
3229
      if fid == 0:
3230
        if ftype == TType.I32:
3231
          self.success = iprot.readI32();
3232
        else:
3233
          iprot.skip(ftype)
3234
      else:
3235
        iprot.skip(ftype)
3236
      iprot.readFieldEnd()
3237
    iprot.readStructEnd()
3238
 
3239
  def write(self, oprot):
3240
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3241
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3242
      return
3243
    oprot.writeStructBegin('getOpenTicketCountForAgent_result')
3244
    if self.success is not None:
3245
      oprot.writeFieldBegin('success', TType.I32, 0)
3246
      oprot.writeI32(self.success)
3247
      oprot.writeFieldEnd()
3248
    oprot.writeFieldStop()
3249
    oprot.writeStructEnd()
3250
 
3251
  def validate(self):
3252
    return
3253
 
3254
 
3255
  def __repr__(self):
3256
    L = ['%s=%r' % (key, value)
3257
      for key, value in self.__dict__.iteritems()]
3258
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3259
 
3260
  def __eq__(self, other):
3261
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3262
 
3263
  def __ne__(self, other):
3264
    return not (self == other)
6104 rajveer 3265
 
3266
class getOpenTicketsMap_args:
3267
 
3268
  thrift_spec = (
3269
  )
3270
 
3271
  def read(self, iprot):
3272
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3273
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3274
      return
3275
    iprot.readStructBegin()
3276
    while True:
3277
      (fname, ftype, fid) = iprot.readFieldBegin()
3278
      if ftype == TType.STOP:
3279
        break
3280
      else:
3281
        iprot.skip(ftype)
3282
      iprot.readFieldEnd()
3283
    iprot.readStructEnd()
3284
 
3285
  def write(self, oprot):
3286
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3287
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3288
      return
3289
    oprot.writeStructBegin('getOpenTicketsMap_args')
3290
    oprot.writeFieldStop()
3291
    oprot.writeStructEnd()
3292
 
3293
  def validate(self):
3294
    return
3295
 
3296
 
3297
  def __repr__(self):
3298
    L = ['%s=%r' % (key, value)
3299
      for key, value in self.__dict__.iteritems()]
3300
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3301
 
3302
  def __eq__(self, other):
3303
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3304
 
3305
  def __ne__(self, other):
3306
    return not (self == other)
3307
 
3308
class getOpenTicketsMap_result:
3309
  """
3310
  Attributes:
3311
   - success
3312
  """
3313
 
3314
  thrift_spec = (
3315
    (0, TType.MAP, 'success', (TType.STRING,None,TType.I64,None), None, ), # 0
3316
  )
3317
 
3318
  def __init__(self, success=None,):
3319
    self.success = success
3320
 
3321
  def read(self, iprot):
3322
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
3323
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
3324
      return
3325
    iprot.readStructBegin()
3326
    while True:
3327
      (fname, ftype, fid) = iprot.readFieldBegin()
3328
      if ftype == TType.STOP:
3329
        break
3330
      if fid == 0:
3331
        if ftype == TType.MAP:
3332
          self.success = {}
3333
          (_ktype85, _vtype86, _size84 ) = iprot.readMapBegin() 
3334
          for _i88 in xrange(_size84):
3335
            _key89 = iprot.readString();
3336
            _val90 = iprot.readI64();
3337
            self.success[_key89] = _val90
3338
          iprot.readMapEnd()
3339
        else:
3340
          iprot.skip(ftype)
3341
      else:
3342
        iprot.skip(ftype)
3343
      iprot.readFieldEnd()
3344
    iprot.readStructEnd()
3345
 
3346
  def write(self, oprot):
3347
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
3348
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
3349
      return
3350
    oprot.writeStructBegin('getOpenTicketsMap_result')
3351
    if self.success is not None:
3352
      oprot.writeFieldBegin('success', TType.MAP, 0)
3353
      oprot.writeMapBegin(TType.STRING, TType.I64, len(self.success))
3354
      for kiter91,viter92 in self.success.items():
3355
        oprot.writeString(kiter91)
3356
        oprot.writeI64(viter92)
3357
      oprot.writeMapEnd()
3358
      oprot.writeFieldEnd()
3359
    oprot.writeFieldStop()
3360
    oprot.writeStructEnd()
3361
 
3362
  def validate(self):
3363
    return
3364
 
3365
 
3366
  def __repr__(self):
3367
    L = ['%s=%r' % (key, value)
3368
      for key, value in self.__dict__.iteritems()]
3369
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
3370
 
3371
  def __eq__(self, other):
3372
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
3373
 
3374
  def __ne__(self, other):
3375
    return not (self == other)