back soft

امروزدخترم رابردم دندانپزشکی .یکی ازهمکاران قدیمی به اسم خانم شریفی رادیدم خوشحال شدم ،راستش برای من فرقی نمی کنه که خاطره خوب ازهمکارام داشته باشم یانه وقتی بعدازمدتهااونهارامی بینم خوشحال میشم،بعدرف, ...ادامه مطلب

امروزدخترم رابردم دندانپزشکی .یکی ازهمکاران قدیمی به اسم خانم شریفی رادیدم خوشحال شدم ،راستش برای من فرقی نمی کنه که خاطره خوب ازهمکارام داشته باشم یانه وقتی بعدازمدتهااونهارامی بینم خوشحال میشم،بعدرف, ...ادامه مطلب

امروزدخترم رابردم دندانپزشکی .یکی ازهمکاران قدیمی به اسم خانم شریفی رادیدم خوشحال شدم ،راستش برای من فرقی نمی کنه که خاطره خوب ازهمکارام داشته باشم یانه وقتی بعدازمدتهااونهارامی بینم خوشحال میشم،بعدرف, ...ادامه مطلب

Vote count: 0 I have job class in my package. Function is simple but time consuming. I'd like send it to run in background. php artisan queue:work works. , ...ادامه مطلب

Vote count: 0 Iam working on ActiveMQ application where iam using a consumer which uses Session.CLIENT_ACKNOWLEDGE. Iam sending the messages received from queue in consumer to a webservice.Assume if i don do message.acknowledge() all the messages sent to webservice are back on the queue in enqueued state. My question is how to retrieve the messages again from the queue and use it.I used retroactive=true and tried redelivery also but all of them are failing. How to avoid this. asked 48 secs agoChetan Sistla Let's block ads! بخوانید,how to retrieve,how to retrieve deleted texts on iphone,how to retrieve deleted emails,how to retrieve deleted text,how to retrieve apple id,how to retrieve deleted texts on iphone 6,how to retrieve old text messages,how to retrieve text messages,how to retrieve deleted emails from gmail,how to retrieve photos from icloud ...ادامه مطلب

Vote count: 0 I have an old Debian (Lenny), on which I develop an application that should connect to RabbitMQ. I downloaded the official C++ client rabbitmq-c-0.8.0 from https://github.com/alanxz/rabbitmq-c/releases/tag/v0.8.0 , but unfortunately, I can't compile it on my old Debian: wget https://github.com/alanxz/rabbitmq-c/archive/v0.8.0.tar.gz tar zxvf v0.8.0.tar.gz autoreconf -i Result: autoreconf -i /usr/share/aclocal/libmcrypt.m4:17: waing: underquoted definition of AM_PATH_LIBMCRYPT /usr/share/aclocal/libmcrypt.m4:17: run info '(automake)Extending aclocal' /usr/share/aclocal/libmcrypt.m4:17: or see http://sources.redhat.com/automake/automake.html#Extending-aclocal Makefile.am:6: Libtool library used but `LIBTOOL' is undefined Makefile.am:6: The usual way to define `LIBTOOL' is to add `AC_PROG_LIBTOOL' Makefile.am:6: to `configure.ac' and run `aclocal' and `auto,rabbitmq c client,rabbitmq c client tutorial,rabbitmq c client windows,rabbitmq c client heartbeat,rabbitmq c client ssl,rabbitmq c client linux,amqp c client,rabbitmq objective-c client,rabbitmq client lib,objective-c-rabbitmq-client-not-publishing-messages-to-queue ...ادامه مطلب

Vote count: 0 Do I have to flush command queue before calling IDXGISwapChain::Present? void MyApp::OnPaint() { //..... FlushCommandQueue(); // flush the command queue. m_dxgiSwapChain->Present( 0, 0 ); } void MyApp::FlushCommandQueue() { m_CommandQueue->Signal( m_Fence, ++m_CurrentFrame ); m_Fence->SetEventOnCompletion( m_CurrentFrame, m_Fence, m_FenceEvent ); WaitForSignleObject( m_FenceEvent, INFINITE ); } asked 24 secs agoCpper.Lee Let's block ads! بخوانید, ...ادامه مطلب

Vote count: 0 I have items in my SQS queue. I then grab 100 items from queue to process and then I want to store the processed items in S3. However, the problem is that since I will be storing 100 items each, there will be numerous pieces of logs in the S3. One way to solve this is to store 100 items locally into a file and then keep updating locally until it reaches a certain threshold. Only after that upload to S3. Is this how it is supposed to work? Thanks. asked 44 secs agomoeseth Let's block ads! بخوانید, ...ادامه مطلب

Vote count: 0 How to use Redis as message queue in asp.net core 1.0? How to connecting Redis in asp.net core 1.0? asked 19 secs agoNeallin Let's block ads! بخوانید, ...ادامه مطلب

Vote count: 0 enter code hereException in thread "AWT-EventQueue-0" java.lang.NullPointerException at dacia.Principale.jButton10ActionPerformed(Principale.java:1204) at dacia.Principale.access$500(Principale.java:44) XSSFWorkbook wg= new XSSFWorkbook(); XSSFSheet sht=wg.createSheet(); TreeMap<String,Object[]> data= new TreeMap<>(); // data.put("-1",new Object[]){"chasis","marque","couleur","nom client","date d entree","date sortie","telephone","numero WW","position","mode paiment","gamme","version"}); data.put("-1",new Object[]{jTable2.getColumnName(0),jTable2.getColumnName(1),jTable2.getColumnName(2),jTable2.getColumnName(3),jTable2.getColumnName(4),jTable2.getColumnName(5),jTable2.getColumnName(6),jTable2.getColumnName(7),jTable2.getColumnName(8),jTable2.getColumnName(9),jTable2.getColumnName(10),jTable2.getColumnName(11)}); for(int i=0;i<jTable2.getRowCount();i++) { data.put(Integer.toString(i),new Object[]{jTable2.getValueAt(i,0).toString(),jTable2.getValueAt(i,1).toString(),jTable2.getValueAt(i,2).toString(),jTable2.getValueAt(i,3).toString(),jTable2.getValueAt(i,4).toString(),jTable2.getValueAt(i,5).toString(),jTable2.getValueAt(i,6).toString(),jTable2.getValueAt(i,7).toString(),jTable2.getValueAt(i,8).toString(),jTable2.getValueAt(i,9).toString(),jTable2.getValueAt(i,10).toString(),jTable2.getValueAt(i,11).toString()}); } //write to excel Set <String> ids=data.keySet(); XSSFRow row ; int roow=0 ; for (String st : ids) { row=sht.createRow(roow++); Object[] values=data.get(st); int cellId=0 ; for(Object o : values) { Cell cell=row.createCell(cellId++); cell.setCellValue(o.toString()); } } try { //write to file FileOutputStream fos= new FileOutputStream(new File("/home/elprincipe/Desktop/dacia.xls")); wg.write(fos); fos.flush(); fos.close(); } catch (FileNotFoun, ...ادامه مطلب

Vote count: -1 I'm implementing an algorithm that involves a variation of BFS using Visual C++. The queue contains objects of type Node* which I am trying to access the members (left and right subtrees) of. For some reason, simply running the following code retus an error: queue<Node*> aQueue; aQueue.push(root); cout << aQueue.front->left;// Error: left of '->data' must point tclass/struct/union/generic type If I'm trying to implement BFS with a queue in C++ and I need to access the members of the Node pointer at the front of the queue, what is the proper way to do it? asked 2 mins agoloremIpsum1771 This entry passed through the Full-Text RSS service - if this is your content and you're reading it on someone else's site, please read the FAQ at fivefilters.org/content-only/faq.php#publishers.Recommended article from FiveFilters.org: Most Labour MPs in the UK Are Revolting., ...ادامه مطلب

Vote count: 0 Im using PHP and ratchet, im dealing with how i can create an event from the serverside and push it to the clients. I know i can use ZeroMQ, but this will also create an overhead, each time an event has to be notify, a new socket connection is made. So i was wondering, wouldnt it better to have thread which is always selecting from a mysql table named "SocketQueue" using memory as engine? Does this architecture makes the app lose the atribute of "Realtime" ? asked 1 min agogabriel mellace This entry passed through the Full-Text RSS service - if this is your content and you're reading it on someone else's site, please read the FAQ at fivefilters.org/content-only/faq.php#publishers.Recommended article from FiveFilters.org: Most Labour MPs in the UK Are Revolting., ...ادامه مطلب

Vote count: 0 When Kafka Consumer is launched from terminal, it is possible to set --from-beginning, so that the consumer read messages from the beginning of a Kafka queue. ~/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic TutorialTopic --from-beginning However, how can I set this parameter in Scala (or Java)? This is my sample ConsumerConfig: def createConsumerConfig(zookeeper: String, groupId: String): ConsumerConfig = { val props = new Properties() props.put("zookeeper.connect", zookeeper); props.put("group.id", groupId); props.put("auto.offset.reset", "largest"); props.put("zookeeper.session.timeout.ms", "400"); props.put("zookeeper.sync.time.ms", "200"); props.put("auto.commit.interval.ms", "1000"); val config = new ConsumerConfig(props) config } asked 30 secs agoKlue Let's block ads! بخوانید, ...ادامه مطلب

Vote count: 0 I've just installed Erlang 19.0, then Rabbitmq Server 3.6.3. OS - Windows 10. Then I installed rabbitmq_management plugin, then I started rabbitmq-server. I can successfully login into management console. The problem is when I go to Queues I get as error: Got response code 500 with body {"error":"JSON encode error: {bad_term,#{error_logger => true,kill => true,size => 0}}","reason":"While encoding: n[{total_count,1},n {item_count,1},n {filtered_count,1},n {page,1},n {page_size,100},n {page_count,1},n {items,n [[{memory,22048},n {reductions,6633},n {reductions_details,[{rate,0.0}]},n {messages,0},n {messages_details,[{rate,0.0}]},n {messages_ready,0},n {messages_ready_details,[{rate,0.0}]},n {messages_unacknowledged,0},n {messages_unacknowledged_details,[{rate,0.0}]},n {idle_since,<<"2016-07-08 20:55:04">>},n {consumer_utilisation,''},n {policy,''},n {exclusive_consumer_tag,''},n {consumers,1},n {recoverable_slaves,''},n {state,running},n {reductions,6633},n {garbage_collection,n [{max_heap_size,#{error_logger => true,kill => true,size => 0}},n {min_bin_vheap_size,46422},n {min_heap_size,233},n {fullsweep_after,65535},n {minor_gcs,3}]},n {messages_ram,0},n {messages_ready_ram,0},n {messages_unacknowledged_ram,0},n {messages_persistent,0},n {message_bytes,0},n {message_bytes_ready,0},n {message_bytes_unacknowledged,0},n {message_bytes_ram,0},n {message_bytes_persistent,0},n {head_message_timestamp,''},n {disk_reads,0},n {disk_writes,0},n {backing_queue_status,n {struct,n [{mode,default},n {q1,0},n {q2,0},n {delta,[delta,undefined,0,undefined]},n {q3,0},n {q4,0},n {len,0},n {target_ram_count,infinity},n {next_seq_id,0},n {avg_ingress_rate,0.0},n {avg_egress_rate,0.0},n {avg_ack_ingress_rate,0.0},n {avg_ack_egress_rate,0.0}]}},n {node,'rabbit@DESKTOP-330SD1I'},n {arguments,{struct,[]}},n {exclusive,false},n {auto_delete,false},n {durable,true},n {vhost,<<"/">>},n {name,<<"queue1">>}]]}]"} If I r, ...ادامه مطلب

Vote count: 0 I can see in the json below we get a xid in all jasons written to the kafka. {"database":"TEST","table":"MAXWELL","type":"insert","ts":1465806121,"xid":2009527,"commit":true,"data":{"id":5,"name":"FIVE"}} {"database":"TEST","table":"MAXWELL","type":"insert","ts":1465806201,"xid":2009701,"commit":true,"data":{"id":6,"name":"SIX"}} What I want to know is, Is this xid unique for each event. This this even is resent for some reason, will that events have the same xid? I tried re-sending the same event by manually changing the positions.binlog_positions and starting a new maxwell instance in a new server. I got same xids for same events from new maxwell instance. I just want to know If this work like that always. So that I can you that xid to uniquely identify a database event. asked 43 secs agoWarWik Let's block ads! بخوانید, ...ادامه مطلب