kaizen23
Hi everyone.This is my first post.I’m sorry for newby question but I have problem with invoke two function in one time.I was created client for RabbitMQ. While I was starting this script sequence of execute function depends on which function is implementation first in method START.Talking about features listen_for_messages(channel, queue_data.queue) and wait_for_message(user, channel).I want to both features “listen” in one time.Function wait_for_message it’s responsible for text which user write while listen_for_messages it’s responsible for recieve messages from another client. Please give me any suggestion because i have no idea how solve this problem.This is my CODE:
defmodule ElixirChat do
def start do
user = IO.gets("Type in your name: ") |> String.strip
IO.puts "Hi #{user}, you just joined a chat room! Type your message in and press enter."
{:ok, conn} = AMQP.Connection.open
{:ok, channel} = AMQP.Channel.open(conn)
{:ok, queue_data } = AMQP.Queue.declare(channel, "")
AMQP.Exchange.fanout(channel, "super.chat")
AMQP.Queue.bind(channel, queue_data.queue, "super.chat")
**listen_for_messages(channel, queue_data.queue)**
** wait_for_message(user, channel)**
end
def display_message(user, message) do
IO.puts "#{user}: #{message}"
end
def wait_for_message(user, channel) do
message = IO.gets("") |> String.strip
publish_message(user, message, channel)
wait_for_message(user, channel)
end
def listen_for_messages(channel, queue_name) do
AMQP.Basic.consume(channel,queue_name,nil,no_ack: true)
receive do
{:basic_deliver, payload, _meta}->
{status, list} = JSON.decode(payload)
display_message(list["user"], list["message"])
listen_for_messages(channel, queue_name)
end
end
def publish_message(user, message, channel) do
{ :ok, data } = JSON.encode([user: user, message: message])
AMQP.Basic.publish channel, "super.chat", "", data
end
end
ElixirChat.start
Trending in Questions
I having some trouble figuring out if I have set myself too strict of standards for my production server. Currently I can handle 75% of r...
New
Hi everyone.
My team and I have been working on a fairly modest app based around video streaming and chat, but we’ve landed a customer t...
New
Hello,
I’m trying to build a basic Phoenix web-app, and I’d like to use Tailwind.
However, when I launch mix phx.server, I get an error...
New
I really like the adapter patterns that ecto, nebulex, waffle, etc. use and would love find something similar for a key management servic...
New
Hello folks!
So at work, we are seeing some situations where we have to define some “fixed” strings that are used across the codebase in...
New
How Can I Optimise Compile Time Dependencies
I have been building an elixir application for about 2 years now. Many modules and files ha...
New
I’m working on a small exercise involving update_in/3, and I came up with this solution:
data = %{
name: "Periodic Table",
category:...
New
Other Trending Topics
A little off-topic, but I feel like people here have a good head on their shoulders.
I used to be quite good at making software. Was luc...
New
Hey. Is there anyone here who creates agents in their apps? Not talking about using agents, but creating them. I’m finding it pretty diff...
New
I fully migrated to my own harness from Anthropic/Gemini and I think it’s time to share it. Welcome DSH, the DeepSeek Harness, fully writ...
New
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
There has been a thread to discuss the Stack Overflow Developer Survey on this forum every year since 2018, so here’s yet another one for...
New
I love Elixir. It’s one of 2 programming languages I’ve ever fallen in love with.
But I don’t use it anymore.
Serverless was the promis...
New
Categories:
Sub Categories:
Forums
Popular Tags
- #ecto
- #liveview
- #troubleshooting
- #learning-elixir
- #library
- #deployment
- #erlang
- #testing
- #genserver
- #mix
- #absinthe
- #remote-other
- #otp
- #plug
- #how-to-question
- #macros
- #postgres
- #elixirconf
- #channels
- #exunit
- #discussion
- #code-sync
- #podcasts
- #javascript
- #onsite
- #dialyzer
- #docker
- #authentication
- #umbrella
- #ai
- #full-time-contract
- #podcasts-by-brainlid
- #ecto-query
- #blog-post
- #elixirconf-us
- #elixir-ls
- #phoenix_html
- #iex
- #graphql
- #genstage
- #websockets
- #supervisor
- #advent-of-code
- #distillery
- #processes
- #elixirconf-eu
- #api
- #forms
- #security
- #metaprogramming










Showing Posts 1 to 3- Show Best Posts
- Show All (oldest first)
- Show All (newest first)
mbuhot
Try running the
listen_for_messagesfunction in another process using spawn: http://elixir-lang.org/getting-started/processes.html#spawnOvermindDL1
Yeah I’d spool it up in a new
Task, which is a simple wrapper around spawn with convenience methods (and can be fit into OTP supervisors, but ignore that part for now)>kaizen23
Hi.@mbuhot.Many thanks for help. This is saved me a lot of time.I didn’t think that could be so simple.It’s WORKING:)