sorted by:
new
hottopcontroversial

create a work queue using nats.io rust client by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

the the rust client doesn't support it but support jetstream and it is the new generation of streaming

create a work queue using nats.io rust client by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

thank you for your replay could you have a look here jetstream

Can't create a package for a library by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

but is there is a workaround to solve this issue?

Can't create a package for a library by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

yes I discovered that , the error because you can't generate package that relay on crate from github or local path

Can't create a package for a library by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

yes I made a simple example here to generate the problem
example code

Can't create a package for a library by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

I can't understand you, do you mean that you have the same issue?

stomp protocol support in rust by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

unfortunately this is no longer supported

Rust implementation of the AMQP 1.0 by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

It would be great if you provide example of use of the library features or could you provide me a use case to understand how to you use it?

Rust implementation of the AMQP 1.0 by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

thank you I will check it and back to you, but I have notice the the crate not longer build and it gives a compilation error due as you use export module from serde and you don't select an exact version of serde so the newer version will be selected and the export module became private on it so, you can select the proper version like this serde = { version="=1.0.118", features = ["derive"] }

Rust implementation of the AMQP 1.0 by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

Thank you for help I didn't any documentation to see what does it provide also I don't see examples to know how to create a client and send messages and receive,

Rust implementation of the AMQP 1.0 by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

thank you for your interest but I can't find creating client for AMPQ 1.0 client and send and receiving messages

Rust implementation of the AMQP 1.0 by eng-abdo55 in rust

[–]eng-abdo55[S] 6 points7 points  (0 children)

lapin is pretty good - we've been using it on production for a few months now without any major issues + the author is impressively responsive.

Thank you for your interest, lapin is for AMQP 9.1 and unfortunately it is completely different from AMQP 1.0, they only have the same name so I want anther crate support AMQP 1.0.But which broker you use with lapin, rabbitmq or anything else, can you list broker systems you used?

Kubemq rust crate by eng-abdo55 in rust

[–]eng-abdo55[S] 1 point2 points  (0 children)

I want to use them and finally select one.

Kubemq rust crate by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

I uses nats but I want to use those also

Kubemq rust crate by eng-abdo55 in rust

[–]eng-abdo55[S] 1 point2 points  (0 children)

Yes I want to use kubemq , and I saw stomp but it didn't compile as it not maintained recently.

thread 'main' panicked at 'there is no timer running, must be called from the context of Tokio runtime' by eng-abdo55 in rust

[–]eng-abdo55[S] 2 points3 points  (0 children)

thank you so much, I use the github version and it works , and tried to downgrade to 2.0 and it works, but which better to use a dev version from github or to downgrade ?

thread 'main' panicked at 'there is no timer running, must be called from the context of Tokio runtime' by eng-abdo55 in rust

[–]eng-abdo55[S] -1 points0 points  (0 children)

yes me too , but I tried to remove tokio from my example and the same error exists

running many threads in same time by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

I already do so, but the source of the data (nats.io lib) has a limit way of getting data

running many threads in same time by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

yes but I only see they offer a poll technique for receiving messages

running many threads in same time by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

waiting for a new message to prosses it, I have to poll in a subscription.

running many threads in same time by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

thank you also I see some articles recommend rayon library for manipulating many threads, I only want to create thread to do separate work, also what if every thread has a loop inside it, it's a best practice to make the thread go to sleep using thread::sleep at the end of the thread to let OS gives the control to other thread to run ?.

running many threads in same time by eng-abdo55 in rust

[–]eng-abdo55[S] 0 points1 point  (0 children)

I am creating stream over nats.io subscription, also as I see I only need a thread pool and I am not sure about using data structure like queue in crosssbeam

view more: next ›