How to get a scheduler and AMQP to work together properly in Ruby? -

-

what want start recurring process every hour publishes batch of messages rmq exchange on our server.

i have class, let's call rmqprocess, fires amqp event loop. thought use rufus-scheduler this:

scheduler.every '10s', :times=>6   process = rmqprocess.new   process.start end  scheduler.join

this works...except each time through loop, amqp channel increases (from 2 4 6 etc...). think means channels not being closed properly, present problem.

i guess summarize question, proper (or @ least proper) way sort of thing? should amqp process fired before entering scheduler process or doing right way? have roll own scheduling logic inside amqp event loop? fear, because seems there must better way. advice appreciated.

for reference, here start method (in case i'm publishing nonsense sentences using randomtext gem):

def start     begin       puts @rmq_params       amqp.start(@rmq_params)          |connection|          connection.on_error           |ch, connection_close|           puts "#{connection_close.reply_text}"         end          connection.on_tcp_connection_loss           |conn, settings|           puts "[network failure] trying reconnect..."           conn.reconnect(false, 2)         end          channel = amqp::channel.new(connection, :auto_recovery => true)         puts "channel id = #{channel.id}"         exchange = channel.direct(@exchangename,:durable => true)         exchange.publish(lorem.words)          em.add_timer(@duration)             connection.close                 em.stop_event_loop             end         end           signal.trap("int")           connection.close             em.stop_event_loop           end         end        end     rescue exception => e       puts "#{e.message} #{e.backtrace.join("\n")}"     end end

does

6.times   process = rmqprocess.new   process.start   sleep(10) end

behave differently?

if i'd "start" amqp outside of rmqprocess#start , re-use resulting connection.


Comments

Post a Comment

Popular posts from this blog

c# - Unity IoC Lifetime per HttpRequest for UserStore -

-
i'm trying clean default implementation of accountcontroller.cs comes out of box in new mvc5/owin security implementation. have modified constructor this: private usermanager<applicationuser> usermanager; public accountcontroller(usermanager<applicationuser> usermanager) { this.usermanager = usermanager; } also, have created lifetime manager unity looks this: public class httpcontextlifetimemanager<t> : lifetimemanager, idisposable { private httpcontextbase _context = null; public httpcontextlifetimemanager() { _context = new httpcontextwrapper(httpcontext.current); } public httpcontextlifetimemanager(httpcontextbase context) { if (context == null) throw new argumentnullexception("context"); _context = context; } public void dispose() { this.removevalue(); } public override object get...
Read more

Change the color of an oval at click in Java AWT -

-
i have draw ovals in java, , @ click change color. beginning tried change color after 20 ms, doesn't work. my code is: public class mycomponentnew extends frame { public graphics2d g2d; public mycomponentnew(string title) { super(title); setsize(400, 550); } @override public void paint(graphics g) { this.g2d = (graphics2d) g; this.g2d.setcolor(color.red); this.g2d.filloval(10, 55, 50, 100); } public void changecolor () { this.g2d.setcolor(color.blue); this.g2d.filloval(10, 55, 50, 100); } } and in class main method have: mycomponentnew m; m = new mycomponentnew("fereastra cu baloane"); m.setvisible(true); m.addwindowlistener(new windowadapter() { @override public void windowclosing(windowevent we) { system.exit(0); } }); try { thread.sleep(20); } catch(interruptedexception e) {} m.changecolor(); the color of oval remains red. ...
Read more

I am trying to solve the error message 'incompatible ranks 0 and 1 in assignment' in a fortran 95 program. -

-
i writing program in fortran find velocity of parachuting person in relation time. keep getting error can't fix. new programming , appreciated. the error is v(i+1)=v(i)+[32-((c*v(i)*v(i))/m)]*(h) 1 error: incompatible ranks 0 , 1 in assignment @ (1) and program is program para integer :: real :: v(11) !velocity real :: q !initial velocity real :: h !time step real :: c !drag coefficient real :: m !mass ! gravity equal 32 ft/s^2 write (*,*)'enter time step' read(*,*)h write(*,*)'enter initial velocity' read(*,*)q write(*,*)'enter drag coefficient' read(*,*)c write(*,*)'enter mass' read(*,*)m i=1,10 ! 1 10, 1 being interval. end v(i+1)=v(i)+[32-((c*v(i)*v(i))/m)]*(h) q=v(1) end program you cannot use [] normal parenthesis in expressions. array constructor, [ items ] means array items elements. end do should after line.
Read more