Class: ISubscribeHandler::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/i_subscribe_handler.rb

Instance Method Summary collapse

Instance Method Details

#process_checkAlbum(seqid, iprot, oprot) ⇒ Object 



145
146
147
148
149
150
 
# File 'lib/i_subscribe_handler.rb', line 145

def process_checkAlbum(seqid, iprot, oprot)
  args = read_args(iprot, CheckAlbum_args)
  result = CheckAlbum_result.new()
  result.success = @handler.checkAlbum(args.uid, args.albumId)
  write_result(result, oprot, 'checkAlbum', seqid)
end

#process_checkSubscribeFlag(seqid, iprot, oprot) ⇒ Object 



152
153
154
155
156
157
 
# File 'lib/i_subscribe_handler.rb', line 152

def process_checkSubscribeFlag(seqid, iprot, oprot)
  args = read_args(iprot, CheckSubscribeFlag_args)
  result = CheckSubscribeFlag_result.new()
  result.success = @handler.checkSubscribeFlag(args.uid)
  write_result(result, oprot, 'checkSubscribeFlag', seqid)
end

#process_getSubscribeFlag(seqid, iprot, oprot) ⇒ Object 



159
160
161
162
163
164
 
# File 'lib/i_subscribe_handler.rb', line 159

def process_getSubscribeFlag(seqid, iprot, oprot)
  args = read_args(iprot, GetSubscribeFlag_args)
  result = GetSubscribeFlag_result.new()
  result.success = @handler.getSubscribeFlag(args.uid)
  write_result(result, oprot, 'getSubscribeFlag', seqid)
end

#process_getSubscriptions(seqid, iprot, oprot) ⇒ Object 



124
125
126
127
128
129
 
# File 'lib/i_subscribe_handler.rb', line 124

def process_getSubscriptions(seqid, iprot, oprot)
  args = read_args(iprot, GetSubscriptions_args)
  result = GetSubscriptions_result.new()
  result.success = @handler.getSubscriptions(args.uid)
  write_result(result, oprot, 'getSubscriptions', seqid)
end

#process_isSubscribe(seqid, iprot, oprot) ⇒ Object 



166
167
168
169
170
171
 
# File 'lib/i_subscribe_handler.rb', line 166

def process_isSubscribe(seqid, iprot, oprot)
  args = read_args(iprot, IsSubscribe_args)
  result = IsSubscribe_result.new()
  result.success = @handler.isSubscribe(args.uid, args.albumIds)
  write_result(result, oprot, 'isSubscribe', seqid)
end

#process_subscribe(seqid, iprot, oprot) ⇒ Object 



131
132
133
134
135
136
 
# File 'lib/i_subscribe_handler.rb', line 131

def process_subscribe(seqid, iprot, oprot)
  args = read_args(iprot, Subscribe_args)
  result = Subscribe_result.new()
  result.success = @handler.subscribe(args.uid, args.albumId)
  write_result(result, oprot, 'subscribe', seqid)
end

#process_unsubscribe(seqid, iprot, oprot) ⇒ Object 



138
139
140
141
142
143
 
# File 'lib/i_subscribe_handler.rb', line 138

def process_unsubscribe(seqid, iprot, oprot)
  args = read_args(iprot, Unsubscribe_args)
  result = Unsubscribe_result.new()
  result.success = @handler.unsubscribe(args.uid, args.albumId)
  write_result(result, oprot, 'unsubscribe', seqid)
end