kegaretail / react-native-rabbitmq Goto Github PK

s.dependency 'React' 
s.dependency 'RMQClient'

import React, { Component } from 'react';

import { Text, TextInput, View, Button, Alert } from 'react-native';
import DeviceInfo from 'react-native-device-info';
// import { Connection, Exchange, Queue } from 'react-native-amqp';
import { Connection, Exchange, Queue } from 'react-native-rabbitmq';
const config = {
  host: 'localhost',
  port: 5672,
  username: 'mq-pub',   //your rabbitmq management username
  password: 'mq-pub',   //your rabbitmq management password
  virtualhost: '/'
};
class App extends Component {
  constructor() {
    super();
    this.state = {
      customerName: '',
      macAddress: '',
      showName: false,
      uniqueId: ''
    };
    this.getUniqueMacId()
  }
  getUniqueMacId() {
    const uniqueId = DeviceInfo.getUniqueId();
    DeviceInfo.getMacAddress().then((mac) => {
      this.setState({ macAddress: mac, uniqueId: uniqueId })
    });
  }
  displayNameHandler = (e) => {
    let updatedName = e.target.value;
    this.setState({ customerName: updatedName });
  }
  handleSubmit = () => {
    this.setState({
      showName: true
    });
    this.connectionEstablished();
  }
  connectionEstablished = () => {
    let connection = new Connection(config)
    console.log("print", config);
    connection.connect()
    connection.on('error', event => {
      connected = false;
      console.log("you are not connected");
    });
    connection.on('connected', (event) => {
      let queue = new Queue(connection, {
        name: this.state.uniqueId,
        passive: false,
        durable: false,
        exclusive: false,
        consumer_arguments: { 'x-priority': 1 }
      });
      let exchange = new Exchange(connection, {
        name: ''
      });
      queue.bind(exchange, this.state.uniqueId);
      exchange.publish('Hello', 'lic_requests', {});
      queue.on('message', (data) => {
        console.log("Message: ", data);
      });
    });
  }
  render() {
    return (
      <View>
        <View style={{ padding: 70, paddingTop: 200 }}>
          <TextInput
            style={{ height: 40 }}
            placeholder="Enter Your Customer Name"
            value={this.state.customerName}
            onChangeText={(text) => this.setState({ customerName: text })}
          />
        </View>
        <View style={{
          padding: 50
        }}>
          <Button
            title="Press me"
            onPress={() => { this.handleSubmit() }}
            disabled={this.state.customerName == "" ? true : false}
          />
        </View>
        <View>
          <Text style={{ paddingLeft: 50 }}>
            Devide Unique Id : {this.state.uniqueId}
          </Text>
          <Text style={{ paddingLeft: 50 }}>
            Device mac Address : {this.state.macAddress}
          </Text>
          {this.state.showName &&
            <Text style={{ paddingLeft: 50 }}>
              Customer Name : {this.state.customerName}
            </Text>}
        </View>
      </View>
    );
  }
}
export default App;

    exchange = new Exchange(connection, {
      name: 'spmq_1001_durable',
      type: 'topic',
      durable: true,
      autoDelete: false,
      internal: false
  });     

   queue.basicAck(data.delivery_tag)
  
    });
    
  });

  connection.on('error', event => {
    console.tron.log("you are not connected");
  });
}

connection.on('connected', (event) => {

    let queue = new Queue( this.connection, {
        name: 'queue_name',
        passive: false,
        durable: true,
        exclusive: false,
        consumer_arguments: {'x-priority': 1}
    });

    let exchange = new Exchange(connection, {
        name: 'exchange_name',
        type: 'direct',
        durable: true,
        autoDelete: false,
        internal: false
    });

    queue.bind(exchange, 'queue_name');

    // Receive one message when it arrives
    queue.on('message', (data) => {
        console.warn(data);
    });
});

yarn add react-native-rabbitmq
cd ios
pod install
cd ..
yarn ios

CompileC /Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/Objects-normal/x86_64/RMQValues.o /Users/mikhailpopov/rabbitmqapp/ios/Pods/RMQClient/RMQClient/RMQValues.m normal x86_64 objective-c com.apple.compilers.llvm.clang.1_0.compiler (in target 'RMQClient' from project 'Pods')
    cd /Users/mikhailpopov/rabbitmqapp/ios/Pods
    export LANG=en_US.US-ASCII
    /Applications/Xcode.app/Contents/Developer/Toolchains/XcodeDefault.xctoolchain/usr/bin/clang -x objective-c -target x86_64-apple-ios8.0-simulator -fmessage-length=0 -fdiagnostics-show-note-include-stack -fmacro-backtrace-limit=0 -std=gnu11 -fobjc-arc -fobjc-weak -fmodules -fmodules-cache-path=/Users/mikhailpopov/Library/Developer/Xcode/DerivedData/ModuleCache.noindex -fmodules-prune-interval=86400 -fmodules-prune-after=345600 -fbuild-session-file=/Users/mikhailpopov/Library/Developer/Xcode/DerivedData/ModuleCache.noindex/Session.modulevalidation -fmodules-validate-once-per-build-session -Wnon-modular-include-in-framework-module -Werror=non-modular-include-in-framework-module -Wno-trigraphs -fpascal-strings -O0 -fno-common -Wno-missing-field-initializers -Wno-missing-prototypes -Werror=return-type -Wdocumentation -Wunreachable-code -Wno-implicit-atomic-properties -Werror=deprecated-objc-isa-usage -Wno-objc-interface-ivars -Werror=objc-root-class -Wno-arc-repeated-use-of-weak -Wimplicit-retain-self -Wduplicate-method-match -Wno-missing-braces -Wparentheses -Wswitch -Wunused-function -Wno-unused-label -Wno-unused-parameter -Wunused-variable -Wunused-value -Wempty-body -Wuninitialized -Wconditional-uninitialized -Wno-unknown-pragmas -Wno-shadow -Wno-four-char-constants -Wno-conversion -Wconstant-conversion -Wint-conversion -Wbool-conversion -Wenum-conversion -Wno-float-conversion -Wnon-literal-null-conversion -Wobjc-literal-conversion -Wshorten-64-to-32 -Wpointer-sign -Wno-newline-eof -Wno-selector -Wno-strict-selector-match -Wundeclared-selector -Wdeprecated-implementations -DPOD_CONFIGURATION_DEBUG=1 -DDEBUG=1 -DCOCOAPODS=1 -DOBJC_OLD_DISPATCH_PROTOTYPES=0 -isysroot /Applications/Xcode.app/Contents/Developer/Platforms/iPhoneSimulator.platform/Developer/SDKs/iPhoneSimulator13.4.sdk -fasm-blocks -fstrict-aliasing -Wprotocol -Wdeprecated-declarations -g -Wno-sign-conversion -Winfinite-recursion -Wcomma -Wblock-capture-autoreleasing -Wstrict-prototypes -Wno-semicolon-before-method-body -Wunguarded-availability -fobjc-abi-version=2 -fobjc-legacy-dispatch -index-store-path /Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Index/DataStore -iquote /Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/RMQClient-generated-files.hmap -I/Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/RMQClient-own-target-headers.hmap -I/Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/RMQClient-all-non-framework-target-headers.hmap -ivfsoverlay /Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/all-product-headers.yaml -iquote /Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/RMQClient-project-headers.hmap -I/Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Products/Debug-iphonesimulator/RMQClient/include -I/Users/mikhailpopov/rabbitmqapp/ios/Pods/Headers/Private -I/Users/mikhailpopov/rabbitmqapp/ios/Pods/Headers/Private/RMQClient -I/Users/mikhailpopov/rabbitmqapp/ios/Pods/Headers/Public -I/Users/mikhailpopov/rabbitmqapp/ios/Pods/Headers/Public/CocoaAsyncSocket -I/Users/mikhailpopov/rabbitmqapp/ios/Pods/Headers/Public/JKVValue -I/Users/mikhailpopov/rabbitmqapp/ios/Pods/Headers/Public/RMQClient -I/Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/DerivedSources-normal/x86_64 -I/Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/DerivedSources/x86_64 -I/Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/DerivedSources -F/Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Products/Debug-iphonesimulator/RMQClient -include /Users/mikhailpopov/rabbitmqapp/ios/Pods/Target\ Support\ Files/RMQClient/RMQClient-prefix.pch -MMD -MT dependencies -MF /Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/Objects-normal/x86_64/RMQValues.d --serialize-diagnostics /Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/Objects-normal/x86_64/RMQValues.dia -c /Users/mikhailpopov/rabbitmqapp/ios/Pods/RMQClient/RMQClient/RMQValues.m -o /Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/Objects-normal/x86_64/RMQValues.o
In file included from /Users/mikhailpopov/rabbitmqapp/ios/Pods/RMQClient/RMQClient/RMQValues.m:52:
/Users/mikhailpopov/rabbitmqapp/ios/Pods/RMQClient/RMQClient/RMQValues.h:53:9: fatal error: module 'JKVValue' not found
@import JKVValue;
 ~~~~~~~^~~~~~~~
1 error generated.

warning: The iOS Simulator deployment target 'IPHONEOS_DEPLOYMENT_TARGET' is set to 7.0, but the range of supported deployment target versions is 8.0 to 13.4.99. (in target 'react-native-rabbitmq' from project 'Pods')
warning: The iOS Simulator deployment target 'IPHONEOS_DEPLOYMENT_TARGET' is set to 6.0, but the range of supported deployment target versions is 8.0 to 13.4.99. (in target 'JKVValue' from project 'Pods')
warning: The iOS Simulator deployment target 'IPHONEOS_DEPLOYMENT_TARGET' is set to 5.0, but the range of supported deployment target versions is 8.0 to 13.4.99. (in target 'CocoaAsyncSocket' from project 'Pods')
warning: The iOS Simulator deployment target 'IPHONEOS_DEPLOYMENT_TARGET' is set to 6.0, but the range of supported deployment target versions is 8.0 to 13.4.99. (in target 'OpenSSL-Universal' from project 'Pods')
warning: no rule to process file '/Users/mikhailpopov/rabbitmqapp/ios/Pods/Flipper-RSocket/rsocket/benchmarks/CMakeLists.txt' of type 'text' for architecture 'x86_64' (in target 'Flipper-RSocket' from project 'Pods')
warning: no rule to process file '/Users/mikhailpopov/rabbitmqapp/ios/Pods/Flipper-RSocket/rsocket/benchmarks/README.md' of type 'net.daringfireball.markdown' for architecture 'x86_64' (in target 'Flipper-RSocket' from project 'Pods')
warning: no rule to process file '/Users/mikhailpopov/rabbitmqapp/ios/Pods/Flipper-RSocket/rsocket/README.md' of type 'net.daringfireball.markdown' for architecture 'x86_64' (in target 'Flipper-RSocket' from project 'Pods')

** BUILD FAILED **


The following build commands failed:
        CompileC /Users/mikhailpopov/Library/Developer/Xcode/DerivedData/rabbitmqapp-concamnrjcysmbaeczdpdaawoiiu/Build/Intermediates.noindex/Pods.build/Debug-iphonesimulator/RMQClient.build/Objects-normal/x86_64/RMQValues.o /Users/mikhailpopov/rabbitmqapp/ios/Pods/RMQClient/RMQClient/RMQValues.m normal x86_64 objective-c com.apple.compilers.llvm.clang.1_0.compiler
(1 failure)

require_relative '../node_modules/react-native/scripts/react_native_pods'
require_relative '../node_modules/@react-native-community/cli-platform-ios/native_modules'

platform :ios, '10.0'

target 'rabbitmqapp' do
  config = use_native_modules!

  use_react_native!(:path => config["reactNativePath"])

  target 'rabbitmqappTests' do
    inherit! :complete
    # Pods for testing
  end

  # Enables Flipper.
  #
  # Note that if you have use_frameworks! enabled, Flipper will not work and
  # you should disable these next few lines.
  use_flipper!
  post_install do |installer|
    flipper_post_install(installer)
  end
end

target 'rabbitmqapp-tvOS' do
  # Pods for rabbitmqapp-tvOS

  target 'rabbitmqapp-tvOSTests' do
    inherit! :search_paths
    # Pods for testing
  end
end

{
  "name": "rabbitmqapp",
  "version": "0.0.1",
  "private": true,
  "scripts": {
    "android": "react-native run-android",
    "ios": "react-native run-ios",
    "start": "react-native start",
    "test": "jest",
    "lint": "eslint ."
  },
  "dependencies": {
    "react": "16.13.1",
    "react-native": "0.63.2",
    "react-native-rabbitmq": "^0.6.7"
  },
  "devDependencies": {
    "@babel/core": "^7.11.0",
    "@babel/runtime": "^7.11.0",
    "@react-native-community/eslint-config": "^2.0.0",
    "babel-jest": "^26.2.2",
    "eslint": "^7.6.0",
    "jest": "^26.2.2",
    "metro-react-native-babel-preset": "^0.61.0",
    "react-test-renderer": "16.13.1"
  },
  "jest": {
    "preset": "react-native"
  }
}

queue.bind(exchange, "my.routing.key");
queue.bind(exchange, "other.routing.key");

connection = new Connection(config);
connection.connect();
let connected = false;

connection.on('connected', (event) => {
    console.log("connected");
    queue = new Queue(connection, {
        name: channel,
        passive: false,
        durable: true,
        exclusive: false,
        // consumer_arguments: { 'x-message-ttl': 1000 },
        // Arguments:{'x-message-ttl': 1000 },
        // ttl:1000,
        autoDelete: false,
    });
    exchange = new Exchange(connection, {
        name: mExchangeName,
        type: 'direct',
        durable:true,
        autoDelete: false,
        internal: false,
    });
    queue.bind(exchange, channel);
    queue.on('message', (data) => {
        console.log(data);
        if(mCallFun)mCallFun(data);
    });
});
connection.on('error', event => {
    connected = false;
    console.log(connection);
    console.log(event);
    console.log("you are not connected");
});

    queue.on('message', (data) => {
        console.log('message', data);
    });
    queue.on('messages', (data) => {
        console.log('messages', data);
        //store.dispatch(actions.rabbitMessages(data));
    });
})