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! بخوانید...

Vote count: 0 I have an old Debian (Ley), on which I develop an application that should coect 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 l...

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 coecting 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 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.ge...

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 ruing the following code retus an error: queue aQueue; aQueue.push(root); cout 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 s...

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 coection 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...

Vote count: 0 When Kafka Consumer is launched from terminal, it is possible to set --from-begiing, so that the consumer read messages from the begiing of a Kafka queue. ~/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic TutorialTopic --from-begiing 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.coect", 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.c...

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,[{...

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...

Vote count: 0 I want to create my own class of QSpinBox and overwriting the valueChanged method to behaviour as I need adding the Qt.QueuedCoection type instead of Qt.AutoCoection here is the code I use : class AbstractSpinBox(QtWidgets.QSpinBox): def __init__(self, parent=None): super(AbstractSpinBox, self).__init__(parent) def valueChanged(self, *args, **kwargs): super(AbstractSpinBox, self).valueChanged(*args, **kwargs) How can I achieve that ? Thank you very much. asked 2 mins agoDarkos Let's block ads! بخوانید...

Vote count: 0 When I submit to gspread it takes some time for data to get uploaded and this hangs my program for a few seconds. I was hoping to just have that submital appended to a local list and in the background have that list uploaded as to not bog down the UI. I am very new to python and while everything works fine (code is abridged below for brevity) I am unable to consistently upload the data without a "main thread not in main loop" exception. I searched for the answer here and at other sites but documentation and help on the queue to thread implementation is few and far between. Any help would be appreciated. Thank you. #!/usr/bin/python import sys from tkinter import * from tkinter....

Vote count: 0 I have a queue that happened to contain wrong parameters for the perform_async worker. I don't want to loose the jobs, but edit arguments so they will succeed next time or on forced retry. Is this possible? asked 1 min agosuperego Let's block ads! بخوانید...

Vote count: 0 In python there's a built-in heapq algorithm that gives you push, pop, nlargest, nsmallest... etc that you can apply to lists. However, there's also the queue.PriorityQueue class that seems to support more or less the same functionality. What's the difference, and when would you use one over the other? asked 2 mins agoYasser 1 Answer Vote count: 0 Queue.PriorityQueue is a thread-safe class, while collections.heapq makes no thread-safety guarantees. From the Queue module documentation: The Queue module implements multi-producer, multi-consumer queues. It is especially useful in threaded programming when information must be exchanged safely between multiple threads. The Queue cla...

Vote count: 0 I know that mWaitingRequest keeps the requests that has the same cacheKey, when a Request is finished, the requests with the same cacheKey will be added to the mCacheQueue. But I don't think this is necessory, why not just add the request with the same cacheKey to the mCacheQueue directly? I just search google, but don't get the answer. asked 1 min agolingnanlu Let's block ads! بخوانید...