kaizen23

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

Showing Posts 1 to 3

mbuhot

mbuhot

Try running the listen_for_messages function in another process using spawn: http://elixir-lang.org/getting-started/processes.html#spawn

OvermindDL1

OvermindDL1

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)> :slight_smile:

kaizen23

kaizen23 OP

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:)

— All posts loaded —

Where Next? Top

Trending in Questions Top

RSP87
I’m working on a project that simulates the bumbl example in the programming phoenix book. It acts almost like an email client. We have a...
New
nseaSeb
Hello, I know there is an approach for handling lists that allows for optimized traversal, but I can’t recall the specific method (somet...
New
brecabral
Documentation While reading the Scoped Routes section, I noticed that the documentation currently refers to a problem without explainin...
New
RemyXRenard
I’m seeing that a list inside a Kino.DataTable will be interpreted as a charlist, even if the Kino.configure() is set to charlists: :as_l...
New
velrest
So my question is quite simple and i have found no conclusive answer on forum, google or AI. Should we use :erlang.float for Integer to ...
New
samoloth
Hi, I’ve just set up an application with ash_authentication. There is only magic link strategy for now, so there is no confirmation add o...
New
FlyingNoodle
If a change or preparation module uses Ash.Changeset.get_argument/2 or Ash.Query.get_argument/2 (or any of the other get_argument functio...
New

Other Trending Topics Top

JesseHerrick
Hey, I’m Jesse and I’m the main contributor behind Dexter, a full-featured, lightning-fast Elixir LSP optimized for large codebases. It s...
New
mudasobwa
I am happy to introduce the very α version of the new programming language compiled to BEAM. Welcome Cure. It has literally three kille...
New
marciok
Hi there! We created Gust: A task orchestrator inspired by Airflow. For those who have never heard about Aiflow, it’s a Python-based wor...
New
mhanberg
Hi everyone! The first release candidate for the Expert language server project is now available! We’ve published a press release detai...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
Dmk
Xamal is a deployment tool for Elixir apps that deploys native releases to bare metal servers over SSH. It’s a port of GitHub - basecamp/...
New

We're in Beta

About us Mission Statement

Options

Thread Display Mode




Thread Preview

Skip Thread Previews