RTMP java Client for video publishing

[gio2375]

Hi all,

I'm trying to write a simple java client to publish a video.

This is my simple class:


import java.io.File;

import org.red5.io.ITagReader;
import org.red5.io.flv.IFLV;
import org.red5.io.flv.impl.FLVService;
import org.red5.io.object.Deserializer;
import org.red5.io.object.Serializer;
import org.red5.io.utils.ObjectMap;
import org.red5.server.api.event.IEvent;
import org.red5.server.api.event.IEventDispatcher;
import org.red5.server.api.service.IPendingServiceCall;
import org.red5.server.api.service.IPendingServiceCallback;
import org.red5.server.cache.NoCacheImpl;
import org.red5.server.net.rtmp.RTMPClient;
import org.red5.server.net.rtmp.RTMPConnection;
import org.red5.server.net.rtmp.RTMPClient.INetStreamEventHandler;
import org.red5.server.net.rtmp.codec.RTMP;
import org.red5.server.net.rtmp.event.IRTMPEvent;
import org.red5.server.net.rtmp.event.Notify;
import org.red5.server.net.rtmp.status.StatusCodes;
import org.red5.server.stream.FileStreamSource;
import org.red5.server.stream.message.RTMPMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyRTMPClientUploader extends RTMPClient implements INetStreamEventHandler, IPendingServiceCallback, IEventDispatcher
{

        private static final Logger logger = LoggerFactory.getLogger(MyRTMPClientUploader.class);

        private int streamId;
        String host = "localhost";
        String app = "oflaDemo";
        int port = 1935;


        public MyRTMPClientUploader() {
                super();

                logger.debug("connecting, host: " + host + ", app: " + app + ", port: " + port);
                connect(host, port, app, this);
                logger.debug("done.");
        }

        @Override
        public void connectionClosed(RTMPConnection conn, RTMP state) {
                logger.debug("connection closed");
                super.connectionClosed(conn, state);
                System.exit(0);
        }

        @Override
        public void createStream(IPendingServiceCallback callback) {
                super.createStream(callback);
                logger.debug("create stream");
                //invoke("createStream", this);
        }


        @Override
        public void dispatchEvent(IEvent eve) {
                logger.debug("dispatchEvent : " + eve);

        }



        @Override
        public void onStreamEvent(Notify notify) {
                logger.debug("onStreamEvent - " + notify);



                if (notify.getCall().getServiceMethodName().equals("onStatus")) {

                        ObjectMap<String, String> map = (ObjectMap) notify.getCall().getArguments()[0];
                        String code = (String) map.get("code");
                        String description = (String) map.get("description");
                        String details = (String) map.get("details");


                        if (StatusCodes.NS_PUBLISH_START.equals(code)) {
                                log.debug("{} for {}", new Object[]{code,details});

                                FLVService service = new FLVService();
                                service.setSerializer(new Serializer());
                                service.setDeserializer(new Deserializer());

                                log.info("Started Publishing");

                            // Read In File And Publish The Data !!
                                try {

                                                File f = new File("C:/Sviluppo/Workspace/MMAWeb/teststreams/earth.flv");
                                                log.debug("test: {}", f);

                                                IFLV flv = (IFLV) service.getStreamableFile(f);
                                                flv.setCache(NoCacheImpl.getInstance());

                                                ITagReader reader = flv.getReader();

                                                FileStreamSource src = new FileStreamSource(reader);

                                                while (src.hasMore())
                                                {
                                                        IRTMPEvent event = src.dequeue();
                                                        RTMPMessage rtmpMsg = new RTMPMessage();
                                                rtmpMsg.setBody(event);

                                                publishStreamData(streamId, rtmpMsg);
                                                }
                                                System.out.println("\nEND!!!!!!!!!!");


                                                disconnect();
                                                //deleteStream(streamId, this);
                                                //unpublish(streamId);

                                } catch (Exception ex) {
                                        log.error(ex.getCause().toString());
                                }
                        }

                        if (StatusCodes.NS_PLAY_STOP.equals(code)) {
                                logger.debug("onStatus code == NetStream.Play.Stop, disconnecting");
                                disconnect();
                        }
                }

        }




        @Override
        synchronized public void resultReceived(IPendingServiceCall call) {
                logger.debug("service call result: " + call);

                Object result = call.getResult();

                if (result instanceof ObjectMap) {
                        if ("connect".equals(call.getServiceMethodName())) {
                                log.info("Connected");
                                createStream(this);
                        }
                }
                else {
                        if ("createStream".equals(call.getServiceMethodName())) {
                                if (result instanceof Integer) {
                                        Integer streamIdInt = (Integer) result;
                                        streamId = streamIdInt.intValue();
                                        log.debug("createStream result stream id: " + streamId);
                                        publish(streamId, "testgio2", "live", this);
                                        log.debug("published stream: " + streamId);
                                } else {
                                        log.debug("DISCONNECT!!!!!");
                                        disconnect();
                                }
                        }
                }
        }





        /**
         * MAIN
         * @param args
         */
        public static void main(String[] args) {

                new MyRTMPClientUploader();

        }
}


It seems to do somethings and seems end without errors but i can't find any video if I open ofla_demo application.

Can someone help me?

Thanks
Giovanni

[Andy Shaules]

Some parts of this message have been removed. Learn more about Nabble's security policy.

Hello,

 

It's not recording because of this.

 

publish(streamId, "testgio2", "live", this);

You are telling it not to record by using 'live' as parameter.

Try 'record'

_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

[gio2375]

Many thanks Andy.....it woks!!!!!!!

Giovanni

Andy Shaules wrote:

Hello,

It's not recording because of this.

publish(streamId, "testgio2", "live", this);You are telling it not to record by using 'live' as parameter.Try 'record'
_______________________________________________
Red5 mailing list
[e-mail]
http://osflash.org/mailman/listinfo/red5_osflash.org

[RAZIB AHMED]

Hi,

I was trying to use this program for pseudo live streaming from saved flv files. I kept the method resultReceived as it is. used "publish(streamId, "testgio2", "live", this);". But it seems that video ends as soon as the "onStreamEvent" method ends broadcasting the video. Client are not being able to get the video file full. If it is already in play mode it can show the starting of the video. keeps playing the audio, but no video after a while. video frames skipping too much frames as well.

how can i make the pseudo live broadcasting from saved flv files? any previous subject on that? i few some. but that lacks of completeness. if there is may i have any link regarding that? nothing more. thank you very much.

One thing more, with Red5 0.8.0 I could not override few methods as connectionClosed, createStream, dispatchEvent. I also could not find "iorg.red5.server.net.rtmp.RTMPClient.INetStreamEventHandler;" class. Could not find any reason to implement "IEventDispatcher". Can I please have your view regarding these problems I faced? which version of RED5 API did you use?

Due to lack of know I would like to know why and how? Please pay your attention.

Razib
26th Feb 2009

gio2375 wrote:

Hi all,

I'm trying to write a simple java client to publish a video.

This is my simple class:


import java.io.File;

import org.red5.io.ITagReader;
import org.red5.io.flv.IFLV;
import org.red5.io.flv.impl.FLVService;
import org.red5.io.object.Deserializer;
import org.red5.io.object.Serializer;
import org.red5.io.utils.ObjectMap;
import org.red5.server.api.event.IEvent;
import org.red5.server.api.event.IEventDispatcher;
import org.red5.server.api.service.IPendingServiceCall;
import org.red5.server.api.service.IPendingServiceCallback;
import org.red5.server.cache.NoCacheImpl;
import org.red5.server.net.rtmp.RTMPClient;
import org.red5.server.net.rtmp.RTMPConnection;
import org.red5.server.net.rtmp.RTMPClient.INetStreamEventHandler;
import org.red5.server.net.rtmp.codec.RTMP;
import org.red5.server.net.rtmp.event.IRTMPEvent;
import org.red5.server.net.rtmp.event.Notify;
import org.red5.server.net.rtmp.status.StatusCodes;
import org.red5.server.stream.FileStreamSource;
import org.red5.server.stream.message.RTMPMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyRTMPClientUploader extends RTMPClient implements INetStreamEventHandler, IPendingServiceCallback, IEventDispatcher
{

        private static final Logger logger = LoggerFactory.getLogger(MyRTMPClientUploader.class);

        private int streamId;
        String host = "localhost";
        String app = "oflaDemo";
        int port = 1935;


        public MyRTMPClientUploader() {
                super();

                logger.debug("connecting, host: " + host + ", app: " + app + ", port: " + port);
                connect(host, port, app, this);
                logger.debug("done.");
        }

        @Override
        public void connectionClosed(RTMPConnection conn, RTMP state) {
                logger.debug("connection closed");
                super.connectionClosed(conn, state);
                System.exit(0);
        }

        @Override
        public void createStream(IPendingServiceCallback callback) {
                super.createStream(callback);
                logger.debug("create stream");
                //invoke("createStream", this);
        }


        @Override
        public void dispatchEvent(IEvent eve) {
                logger.debug("dispatchEvent : " + eve);

        }



        @Override
        public void onStreamEvent(Notify notify) {
                logger.debug("onStreamEvent - " + notify);



                if (notify.getCall().getServiceMethodName().equals("onStatus")) {

                        ObjectMap<String, String> map = (ObjectMap) notify.getCall().getArguments()[0];
                        String code = (String) map.get("code");
                        String description = (String) map.get("description");
                        String details = (String) map.get("details");


                        if (StatusCodes.NS_PUBLISH_START.equals(code)) {
                                log.debug("{} for {}", new Object[]{code,details});

                                FLVService service = new FLVService();
                                service.setSerializer(new Serializer());
                                service.setDeserializer(new Deserializer());

                                log.info("Started Publishing");

                            // Read In File And Publish The Data !!
                                try {

                                                File f = new File("C:/Sviluppo/Workspace/MMAWeb/teststreams/earth.flv");
                                                log.debug("test: {}", f);

                                                IFLV flv = (IFLV) service.getStreamableFile(f);
                                                flv.setCache(NoCacheImpl.getInstance());

                                                ITagReader reader = flv.getReader();

                                                FileStreamSource src = new FileStreamSource(reader);

                                                while (src.hasMore())
                                                {
                                                        IRTMPEvent event = src.dequeue();
                                                        RTMPMessage rtmpMsg = new RTMPMessage();
                                                rtmpMsg.setBody(event);

                                                publishStreamData(streamId, rtmpMsg);
                                                }
                                                System.out.println("\nEND!!!!!!!!!!");


                                                disconnect();
                                                //deleteStream(streamId, this);
                                                //unpublish(streamId);

                                } catch (Exception ex) {
                                        log.error(ex.getCause().toString());
                                }
                        }

                        if (StatusCodes.NS_PLAY_STOP.equals(code)) {
                                logger.debug("onStatus code == NetStream.Play.Stop, disconnecting");
                                disconnect();
                        }
                }

        }




        @Override
        synchronized public void resultReceived(IPendingServiceCall call) {
                logger.debug("service call result: " + call);

                Object result = call.getResult();

                if (result instanceof ObjectMap) {
                        if ("connect".equals(call.getServiceMethodName())) {
                                log.info("Connected");
                                createStream(this);
                        }
                }
                else {
                        if ("createStream".equals(call.getServiceMethodName())) {
                                if (result instanceof Integer) {
                                        Integer streamIdInt = (Integer) result;
                                        streamId = streamIdInt.intValue();
                                        log.debug("createStream result stream id: " + streamId);
                                        publish(streamId, "testgio2", "live", this);
                                        log.debug("published stream: " + streamId);
                                } else {
                                        log.debug("DISCONNECT!!!!!");
                                        disconnect();
                                }
                        }
                }
        }





        /**
         * MAIN
         * @param args
         */
        public static void main(String[] args) {

                new MyRTMPClientUploader();

        }
}


It seems to do somethings and seems end without errors but i can't find any video if I open ofla_demo application.

Can someone help me?

Thanks
Giovanni

[janiparthiv]

Hi all,

I'm trying to use this program with red5 version 8 but am getting following debug and not getting video in oflaDemo folder.


import java.io.File;

import org.red5.io.ITagReader;
import org.red5.io.flv.IFLV;
import org.red5.io.flv.impl.FLVService;
import org.red5.io.object.Deserializer;
import org.red5.io.object.Serializer;
import org.red5.io.utils.ObjectMap;
import org.red5.server.api.event.IEvent;
import org.red5.server.api.event.IEventDispatcher;
import org.red5.server.api.service.IPendingServiceCall;
import org.red5.server.api.service.IPendingServiceCallback;
import org.red5.server.cache.NoCacheImpl;
import org.red5.server.net.rtmp.RTMPClient;
import org.red5.server.net.rtmp.RTMPConnection;
import org.red5.server.net.rtmp.RTMPClient.INetStreamEventHandler;
import org.red5.server.net.rtmp.codec.RTMP;
import org.red5.server.net.rtmp.event.IRTMPEvent;
import org.red5.server.net.rtmp.event.Notify;
import org.red5.server.net.rtmp.status.StatusCodes;
import org.red5.server.stream.FileStreamSource;
import org.red5.server.stream.message.RTMPMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyRTMPClientUploader extends RTMPClient implements INetStreamEventHandler, IPendingServiceCallback, IEventDispatcher
{

        private static final Logger logger = LoggerFactory.getLogger(MyRTMPClientUploader.class);

        private int streamId;
        String host = "localhost";
        String app = "oflaDemo";
        int port = 1935;


        public MyRTMPClientUploader() {
                super();

                logger.debug("connecting, host: " + host + ", app: " + app + ", port: " + port);
                connect(host, port, app, this);
                logger.debug("done.");
        }

        @Override
        public void connectionClosed(RTMPConnection conn, RTMP state) {
                logger.debug("connection closed");
                super.connectionClosed(conn, state);
                System.exit(0);
        }

        @Override
        public void createStream(IPendingServiceCallback callback) {
                super.createStream(callback);
                logger.debug("create stream");
                //invoke("createStream", this);
        }


        @Override
        public void dispatchEvent(IEvent eve) {
                logger.debug("dispatchEvent : " + eve);

        }



        @Override
        public void onStreamEvent(Notify notify) {
                logger.debug("onStreamEvent - " + notify);



                if (notify.getCall().getServiceMethodName().equals("onStatus")) {

                        ObjectMap<String, String> map = (ObjectMap) notify.getCall().getArguments()[0];
                        String code = (String) map.get("code");
                        String description = (String) map.get("description");
                        String details = (String) map.get("details");


                        if (StatusCodes.NS_PUBLISH_START.equals(code)) {
                                log.debug("{} for {}", new Object[]{code,details});

                                FLVService service = new FLVService();
                                service.setSerializer(new Serializer());
                                service.setDeserializer(new Deserializer());

                                log.info("Started Publishing");

                            // Read In File And Publish The Data !!
                                try {

                                                File f = new File("C:/Sviluppo/Workspace/MMAWeb/teststreams/earth.flv");
                                                log.debug("test: {}", f);

                                                IFLV flv = (IFLV) service.getStreamableFile(f);
                                                flv.setCache(NoCacheImpl.getInstance());

                                                ITagReader reader = flv.getReader();

                                                FileStreamSource src = new FileStreamSource(reader);

                                                while (src.hasMore())
                                                {
                                                        IRTMPEvent event = src.dequeue();
                                                        RTMPMessage rtmpMsg = new RTMPMessage();
                                                rtmpMsg.setBody(event);

                                                publishStreamData(streamId, rtmpMsg);
                                                }
                                                System.out.println("\nEND!!!!!!!!!!");


                                                disconnect();
                                                //deleteStream(streamId, this);
                                                //unpublish(streamId);

                                } catch (Exception ex) {
                                        log.error(ex.getCause().toString());
                                }
                        }

                        if (StatusCodes.NS_PLAY_STOP.equals(code)) {
                                logger.debug("onStatus code == NetStream.Play.Stop, disconnecting");
                                disconnect();
                        }
                }

        }




        @Override
        synchronized public void resultReceived(IPendingServiceCall call) {
                logger.debug("service call result: " + call);

                Object result = call.getResult();

                if (result instanceof ObjectMap) {
                        if ("connect".equals(call.getServiceMethodName())) {
                                log.info("Connected");
                                createStream(this);
                        }
                }
                else {
                        if ("createStream".equals(call.getServiceMethodName())) {
                                if (result instanceof Integer) {
                                        Integer streamIdInt = (Integer) result;
                                        streamId = streamIdInt.intValue();
                                        log.debug("createStream result stream id: " + streamId);
                                        publish(streamId, "testgio2", "live", this);
                                        log.debug("published stream: " + streamId);
                                } else {
                                        log.debug("DISCONNECT!!!!!");
                                        disconnect();
                                }
                        }
                }
        }





        /**
         * MAIN
         * @param args
         */
        public static void main(String[] args) {

                new MyRTMPClientUploader();

        }
}


It seems to do somethings and seems end without errors but i can't find any video if I open ofla_demo application.

Can someone help me?

Debug :


18:24:41.078 [main] DEBUG test.MyRTMPClientUploader - connecting, host: localhost, app: oflaDemo, port: 8088
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect server: localhost port 8088 application oflaDemo connectCallback test.MyRTMPClientUploader@131f71a
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect server: localhost port 8088 connectionParams {objectEncoding=0, app=oflaDemo, flashVer=WIN 9,0,115,0, fpad=false, tcUrl=rtmp://localhost:8088/oflaDemo, audioCodecs=1639, videoFunction=1, pageUrl=null, path=oflaDemo, capabilities=15, swfUrl=null, videoCodecs=252} connectCallback test.MyRTMPClientUploader@131f71a conectCallArguments null
18:24:41.140 [main] DEBUG test.MyRTMPClientUploader - done.
18:24:41.156 [SocketConnectorIoProcessor-0.0] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler - Session created
18:24:41.171 [SocketConnectorIoProcessor-0.0] DEBUG o.r.s.net.rtmp.RTMPClientConnManager - Creating connection, class: org.red5.server.net.rtmp.RTMPMinaConnection
18:24:41.187 [SocketConnectorIoProcessor-0.0] INFO  o.r.s.net.rtmp.RTMPMinaConnection - RTMPMinaConnection created
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG o.r.s.net.rtmp.RTMPClientConnManager - Connection id set 0
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG o.r.s.net.rtmp.RTMPClientConnManager - Connection added to the map
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG o.r.server.net.rtmp.RTMPConnection - Set state: org.red5.server.net.rtmp.codec.RTMP@21b6d
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG o.a.m.filter.executor.ExecutorFilter - Launching thread for localhost/127.0.0.1:8088
18:24:41.187 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler - [localhost/127.0.0.1:8088] OPENED
18:24:41.187 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler - Handshake 1st phase
18:24:41.328 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler - [localhost/127.0.0.1:8088] WRITE: DirectBuffer[pos=0 lim=1537 cap=2048: 03 01 86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70 0E D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B 0E B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC F8 84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E 77 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7 7B F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35 51 03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2 15 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A 59 09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3 00 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52 03 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12 0B 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E A1 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB 1C 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75 1F B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07 9D 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5 78 E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03 37 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE 57 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF D7 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2 49 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32 16 11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A 13 03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0 4C 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98 83 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF 9C C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85 56 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8 D9 8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC CE 1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0 EC 53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68 B7 DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D BD FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D 5F D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9 52 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26 4C 5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35 19 59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B 79 38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40 4A ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F 10 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB DE DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E 9D 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94 75 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA F4 19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9 C5 1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D 77 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15 D5 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2 27 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11 6C 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A 5B 1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA BE B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF 0B DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16 B2 90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D FD DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70 CE 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3 C4 12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7 45 A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B F5 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B 2B AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96 50 07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69 89 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75 85 2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB 9C CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler - [localhost/127.0.0.1:8088] SENT: DirectBuffer[pos=0 lim=1537 cap=2048: 03 01 86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70 0E D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B 0E B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC F8 84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E 77 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7 7B F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35 51 03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2 15 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A 59 09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3 00 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52 03 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12 0B 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E A1 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB 1C 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75 1F B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07 9D 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5 78 E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03 37 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE 57 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF D7 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2 49 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32 16 11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A 13 03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0 4C 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98 83 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF 9C C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85 56 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8 D9 8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC CE 1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0 EC 53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68 B7 DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D BD FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D 5F D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9 52 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26 4C 5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35 19 59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B 79 38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40 4A ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F 10 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB DE DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E 9D 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94 75 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA F4 19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9 C5 1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D 77 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15 D5 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2 27 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11 6C 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A 5B 1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA BE B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF 0B DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16 B2 90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D FD DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70 CE 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3 C4 12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7 45 A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B F5 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B 2B AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96 50 07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69 89 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75 85 2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB 9C CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler - messageSent
18:24:41.343 [AnonymousIoService-1] DEBUG o.r.server.net.rtmp.BaseRTMPHandler - Message sent
18:24:41.343 [AnonymousIoService-1] DEBUG o.a.m.filter.executor.ExecutorFilter - Exiting since queue is empty for localhost/127.0.0.1:8088
18:25:41.375 [SocketConnectorIoProcessor-0.0] DEBUG o.a.m.filter.executor.ExecutorFilter - Launching thread for localhost/127.0.0.1:8088
18:25:41.375 [AnonymousIoService-2] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler - [localhost/127.0.0.1:8088] CLOSED
18:25:41.375 [AnonymousIoService-2] DEBUG test.MyRTMPClientUploader - connection closed
18:25:41.375 [AnonymousIoService-2] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connectionClosed
18:25:41.375 [AnonymousIoService-2] DEBUG org.red5.server.BaseConnection - Close, not connected nothing to do.
18:25:41.406 [AnonymousIoService-2] DEBUG org.red5.server.jmx.JMXAgent - leaving unregisterMBean...


Any one help me?

Thank you in advance,

Parthiv

[janiparthiv]

i am using your program with red5 version 8.

i am not getting video in oflademo folder. i am getting error please see below debugs which i am getting in console.


18:24:41.078 [main] DEBUG test.MyRTMPClientUploader - connecting, host: localhost, app: oflaDemo, port: 8088
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect server: localhost port 8088 application oflaDemo connectCallback test.MyRTMPClientUploader@131f71a
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect server: localhost port 8088 connectionParams {objectEncoding=0, app=oflaDemo, flashVer=WIN 9,0,115,0, fpad=false, tcUrl=rtmp://localhost:8088/oflaDemo, audioCodecs=1639, videoFunction=1, pageUrl=null, path=oflaDemo, capabilities=15, swfUrl=null, videoCodecs=252} connectCallback test.MyRTMPClientUploader@131f71a conectCallArguments null
18:24:41.140 [main] DEBUG test.MyRTMPClientUploader - done.
18:24:41.156 [SocketConnectorIoProcessor-0.0] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler - Session created
18:24:41.171 [SocketConnectorIoProcessor-0.0] DEBUG o.r.s.net.rtmp.RTMPClientConnManager - Creating connection, class: org.red5.server.net.rtmp.RTMPMinaConnection
18:24:41.187 [SocketConnectorIoProcessor-0.0] INFO  o.r.s.net.rtmp.RTMPMinaConnection - RTMPMinaConnection created
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG o.r.s.net.rtmp.RTMPClientConnManager - Connection id set 0
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG o.r.s.net.rtmp.RTMPClientConnManager - Connection added to the map
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG o.r.server.net.rtmp.RTMPConnection - Set state: org.red5.server.net.rtmp.codec.RTMP@21b6d
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG o.a.m.filter.executor.ExecutorFilter - Launching thread for localhost/127.0.0.1:8088
18:24:41.187 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler - [localhost/127.0.0.1:8088] OPENED
18:24:41.187 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler - Handshake 1st phase
18:24:41.328 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler - [localhost/127.0.0.1:8088] WRITE: DirectBuffer[pos=0 lim=1537 cap=2048: 03 01 86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70 0E D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B 0E B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC F8 84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E 77 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7 7B F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35 51 03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2 15 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A 59 09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3 00 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52 03 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12 0B 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E A1 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB 1C 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75 1F B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07 9D 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5 78 E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03 37 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE 57 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF D7 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2 49 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32 16 11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A 13 03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0 4C 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98 83 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF 9C C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85 56 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8 D9 8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC CE 1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0 EC 53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68 B7 DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D BD FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D 5F D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9 52 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26 4C 5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35 19 59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B 79 38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40 4A ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F 10 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB DE DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E 9D 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94 75 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA F4 19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9 C5 1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D 77 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15 D5 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2 27 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11 6C 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A 5B 1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA BE B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF 0B DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16 B2 90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D FD DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70 CE 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3 C4 12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7 45 A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B F5 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B 2B AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96 50 07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69 89 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75 85 2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB 9C CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler - [localhost/127.0.0.1:8088] SENT: DirectBuffer[pos=0 lim=1537 cap=2048: 03 01 86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70 0E D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B 0E B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC F8 84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E 77 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7 7B F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35 51 03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2 15 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A 59 09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3 00 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52 03 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12 0B 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E A1 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB 1C 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75 1F B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07 9D 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5 78 E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03 37 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE 57 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF D7 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2 49 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32 16 11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A 13 03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0 4C 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98 83 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF 9C C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85 56 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8 D9 8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC CE 1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0 EC 53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68 B7 DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D BD FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D 5F D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9 52 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26 4C 5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35 19 59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B 79 38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40 4A ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F 10 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB DE DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E 9D 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94 75 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA F4 19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9 C5 1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D 77 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15 D5 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2 27 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11 6C 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A 5B 1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA BE B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF 0B DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16 B2 90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D FD DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70 CE 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3 C4 12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7 45 A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B F5 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B 2B AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96 50 07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69 89 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75 85 2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB 9C CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler - messageSent
18:24:41.343 [AnonymousIoService-1] DEBUG o.r.server.net.rtmp.BaseRTMPHandler - Message sent
18:24:41.343 [AnonymousIoService-1] DEBUG o.a.m.filter.executor.ExecutorFilter - Exiting since queue is empty for localhost/127.0.0.1:8088
18:25:41.375 [SocketConnectorIoProcessor-0.0] DEBUG o.a.m.filter.executor.ExecutorFilter - Launching thread for localhost/127.0.0.1:8088
18:25:41.375 [AnonymousIoService-2] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler - [localhost/127.0.0.1:8088] CLOSED
18:25:41.375 [AnonymousIoService-2] DEBUG test.MyRTMPClientUploader - connection closed
18:25:41.375 [AnonymousIoService-2] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connectionClosed
18:25:41.375 [AnonymousIoService-2] DEBUG org.red5.server.BaseConnection - Close, not connected nothing to do.
18:25:41.406 [AnonymousIoService-2] DEBUG org.red5.server.jmx.JMXAgent - leaving unregisterMBean...



please do needful.

Thank you
Parthiv

[Manuel Raña]

Change:

publish(streamId, "testgio2", "live", this);

by

publish(streamId, "testgio2", "record", this);

???

2009/5/14 janiparthiv <janiparthiv@...>

Hi all,

I'm trying to use this program with red5 version 8 but am getting following
debug and not getting video in oflaDemo folder.


import java.io.File;

import org.red5.io.ITagReader;
import org.red5.io.flv.IFLV;
import org.red5.io.flv.impl.FLVService;
import org.red5.io.object.Deserializer;
import org.red5.io.object.Serializer;
import org.red5.io.utils.ObjectMap;
import org.red5.server.api.event.IEvent;
import org.red5.server.api.event.IEventDispatcher;
import org.red5.server.api.service.IPendingServiceCall;
import org.red5.server.api.service.IPendingServiceCallback;
import org.red5.server.cache.NoCacheImpl;
import org.red5.server.net.rtmp.RTMPClient;
import org.red5.server.net.rtmp.RTMPConnection;
import org.red5.server.net.rtmp.RTMPClient.INetStreamEventHandler;
import org.red5.server.net.rtmp.codec.RTMP;
import org.red5.server.net.rtmp.event.IRTMPEvent;
import org.red5.server.net.rtmp.event.Notify;
import org.red5.server.net.rtmp.status.StatusCodes;
import org.red5.server.stream.FileStreamSource;
import org.red5.server.stream.message.RTMPMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyRTMPClientUploader extends RTMPClient implements
INetStreamEventHandler, IPendingServiceCallback, IEventDispatcher
{

       private static final Logger logger =
LoggerFactory.getLogger(MyRTMPClientUploader.class);

       private int streamId;
       String host = "localhost";
       String app = "oflaDemo";
       int port = 1935;


       public MyRTMPClientUploader() {
               super();

               logger.debug("connecting, host: " + host + ", app: " + app + ", port: " +
port);
               connect(host, port, app, this);
               logger.debug("done.");
       }

       @Override
       public void connectionClosed(RTMPConnection conn, RTMP state) {
               logger.debug("connection closed");
               super.connectionClosed(conn, state);
               System.exit(0);
       }

       @Override
       public void createStream(IPendingServiceCallback callback) {
               super.createStream(callback);
               logger.debug("create stream");
               //invoke("createStream", this);
       }


       @Override
       public void dispatchEvent(IEvent eve) {
               logger.debug("dispatchEvent : " + eve);

       }



       @Override
       public void onStreamEvent(Notify notify) {
               logger.debug("onStreamEvent - " + notify);



               if (notify.getCall().getServiceMethodName().equals("onStatus")) {

                       ObjectMap<String, String> map = (ObjectMap)
notify.getCall().getArguments()[0];
                       String code = (String) map.get("code");
                       String description = (String) map.get("description");
                       String details = (String) map.get("details");


                       if (StatusCodes.NS_PUBLISH_START.equals(code)) {
                               log.debug("{} for {}", new Object[]{code,details});

                               FLVService service = new FLVService();
                               service.setSerializer(new Serializer());
                               service.setDeserializer(new Deserializer());

                               log.info("Started Publishing");

                           // Read In File And Publish The Data !!
                               try {

                                               File f = new
File("C:/Sviluppo/Workspace/MMAWeb/teststreams/earth.flv");
                                               log.debug("test: {}", f);

                                               IFLV flv = (IFLV) service.getStreamableFile(f);
                                               flv.setCache(NoCacheImpl.getInstance());

                                               ITagReader reader = flv.getReader();

                                               FileStreamSource src = new FileStreamSource(reader);

                                               while (src.hasMore())
                                               {
                                                       IRTMPEvent event = src.dequeue();
                                                       RTMPMessage rtmpMsg = new RTMPMessage();
                                               rtmpMsg.setBody(event);

                                               publishStreamData(streamId, rtmpMsg);
                                               }
                                               System.out.println("\nEND!!!!!!!!!!");


                                               disconnect();
                                               //deleteStream(streamId, this);
                                               //unpublish(streamId);

                               } catch (Exception ex) {
                                       log.error(ex.getCause().toString());
                               }
                       }

                       if (StatusCodes.NS_PLAY_STOP.equals(code)) {
                               logger.debug("onStatus code == NetStream.Play.Stop, disconnecting");
                               disconnect();
                       }
               }

       }




       @Override
       synchronized public void resultReceived(IPendingServiceCall call) {
               logger.debug("service call result: " + call);

               Object result = call.getResult();

               if (result instanceof ObjectMap) {
                       if ("connect".equals(call.getServiceMethodName())) {
                               log.info("Connected");
                               createStream(this);
                       }
               }
               else {
                       if ("createStream".equals(call.getServiceMethodName())) {
                               if (result instanceof Integer) {
                                       Integer streamIdInt = (Integer) result;
                                       streamId = streamIdInt.intValue();
                                       log.debug("createStream result stream id: " + streamId);
                                       publish(streamId, "testgio2", "live", this);
                                       log.debug("published stream: " + streamId);
                               } else {
                                       log.debug("DISCONNECT!!!!!");
                                       disconnect();
                               }
                       }
               }
       }





       /**
        * MAIN
        * @param args
        */
       public static void main(String[] args) {

               new MyRTMPClientUploader();

       }
}


It seems to do somethings and seems end without errors but i can't find any
video if I open ofla_demo application.

Can someone help me?

Debug :


18:24:41.078 [main] DEBUG test.MyRTMPClientUploader - connecting, host:
localhost, app: oflaDemo, port: 8088
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect
server: localhost port 8088 application oflaDemo connectCallback
test.MyRTMPClientUploader@131f71a
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect
server: localhost port 8088 connectionParams {objectEncoding=0,
app=oflaDemo, flashVer=WIN 9,0,115,0, fpad=false,
tcUrl=rtmp://localhost:8088/oflaDemo, audioCodecs=1639, videoFunction=1,
pageUrl=null, path=oflaDemo, capabilities=15, swfUrl=null, videoCodecs=252}
connectCallback test.MyRTMPClientUploader@131f71a conectCallArguments null
18:24:41.140 [main] DEBUG test.MyRTMPClientUploader - done.
18:24:41.156 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPMinaIoHandler - Session created
18:24:41.171 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Creating connection, class:
org.red5.server.net.rtmp.RTMPMinaConnection
18:24:41.187 [SocketConnectorIoProcessor-0.0] INFO
o.r.s.net.rtmp.RTMPMinaConnection - RTMPMinaConnection created
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Connection id set 0
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Connection added to the map
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.server.net.rtmp.RTMPConnection - Set state:
org.red5.server.net.rtmp.codec.RTMP@21b6d
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.a.m.filter.executor.ExecutorFilter - Launching thread for
localhost/127.0.0.1:8088
18:24:41.187 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] OPENED
18:24:41.187 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler -
Handshake 1st phase
18:24:41.328 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] WRITE: DirectBuffer[pos=0 lim=1537 cap=2048: 03
01 86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70
0E D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B
0E B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC
F8 84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E
77 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7
7B F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35
51 03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2
15 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A
59 09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3
00 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52
03 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12
0B 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E
A1 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB
1C 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75
1F B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07
9D 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5
78 E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03
37 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE
57 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF
D7 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2
49 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32
16 11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A
13 03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0
4C 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98
83 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF
9C C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85
56 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8
D9 8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC
CE 1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0
EC 53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68
B7 DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D
BD FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D
5F D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9
52 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26
4C 5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35
19 59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B
79 38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40
4A ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F
10 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB
DE DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E
9D 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94
75 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA
F4 19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9
C5 1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D
77 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15
D5 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2
27 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11
6C 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A
5B 1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA
BE B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF
0B DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16
B2 90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D
FD DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70
CE 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3
C4 12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7
45 A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B
F5 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B
2B AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96
50 07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69
89 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75
85 2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB
9C CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] SENT: DirectBuffer[pos=0 lim=1537 cap=2048: 03 01
86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70 0E
D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B 0E
B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC F8
84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E 77
67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7 7B
F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35 51
03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2 15
10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A 59
09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3 00
3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52 03
01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12 0B
04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E A1
03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB 1C
2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75 1F
B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07 9D
93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5 78
E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03 37
8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE 57
C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF D7
33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2 49
E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32 16
11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A 13
03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0 4C
4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98 83
E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF 9C
C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85 56
E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8 D9
8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC CE
1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0 EC
53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68 B7
DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D BD
FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D 5F
D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9 52
94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26 4C
5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35 19
59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B 79
38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40 4A
ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F 10
3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB DE
DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E 9D
50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94 75
E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA F4
19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9 C5
1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D 77
36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15 D5
5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2 27
73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11 6C
03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A 5B
1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA BE
B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF 0B
DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16 B2
90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D FD
DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70 CE
34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3 C4
12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7 45
A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B F5
11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B 2B
AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96 50
07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69 89
F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75 85
2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB 9C
CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler -
messageSent
18:24:41.343 [AnonymousIoService-1] DEBUG
o.r.server.net.rtmp.BaseRTMPHandler - Message sent
18:24:41.343 [AnonymousIoService-1] DEBUG
o.a.m.filter.executor.ExecutorFilter - Exiting since queue is empty for
localhost/127.0.0.1:8088
18:25:41.375 [SocketConnectorIoProcessor-0.0] DEBUG
o.a.m.filter.executor.ExecutorFilter - Launching thread for
localhost/127.0.0.1:8088
18:25:41.375 [AnonymousIoService-2] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] CLOSED
18:25:41.375 [AnonymousIoService-2] DEBUG test.MyRTMPClientUploader -
connection closed
18:25:41.375 [AnonymousIoService-2] DEBUG
o.r.s.net.rtmp.BaseRTMPClientHandler - connectionClosed
18:25:41.375 [AnonymousIoService-2] DEBUG org.red5.server.BaseConnection -
Close, not connected nothing to do.
18:25:41.406 [AnonymousIoService-2] DEBUG org.red5.server.jmx.JMXAgent -
leaving unregisterMBean...


Any one help me?

Thank you in advance,

Parthiv
--
View this message in context: http://www.nabble.com/RTMP-java-Client-for-video-publishing-tp20939125p23540327.html
Sent from the Red5 - English mailing list archive at Nabble.com.


_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

[janiparthiv]

Hi,

i have done this but still i am not getting video in oflademo folder

and getting the same debug.

Do you think i need to check any other configurations.

On Thu, May 14, 2009 at 7:29 PM, Manuel Raña <info@...> wrote:

Change:

publish(streamId, "testgio2", "live", this);

by

publish(streamId, "testgio2", "record", this);

???

2009/5/14 janiparthiv <janiparthiv@...>

Hi all,

I'm trying to use this program with red5 version 8 but am getting following
debug and not getting video in oflaDemo folder.


import java.io.File;

import org.red5.io.ITagReader;
import org.red5.io.flv.IFLV;
import org.red5.io.flv.impl.FLVService;
import org.red5.io.object.Deserializer;
import org.red5.io.object.Serializer;
import org.red5.io.utils.ObjectMap;
import org.red5.server.api.event.IEvent;
import org.red5.server.api.event.IEventDispatcher;
import org.red5.server.api.service.IPendingServiceCall;
import org.red5.server.api.service.IPendingServiceCallback;
import org.red5.server.cache.NoCacheImpl;
import org.red5.server.net.rtmp.RTMPClient;
import org.red5.server.net.rtmp.RTMPConnection;
import org.red5.server.net.rtmp.RTMPClient.INetStreamEventHandler;
import org.red5.server.net.rtmp.codec.RTMP;
import org.red5.server.net.rtmp.event.IRTMPEvent;
import org.red5.server.net.rtmp.event.Notify;
import org.red5.server.net.rtmp.status.StatusCodes;
import org.red5.server.stream.FileStreamSource;
import org.red5.server.stream.message.RTMPMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyRTMPClientUploader extends RTMPClient implements
INetStreamEventHandler, IPendingServiceCallback, IEventDispatcher
{

       private static final Logger logger =
LoggerFactory.getLogger(MyRTMPClientUploader.class);

       private int streamId;
       String host = "localhost";
       String app = "oflaDemo";
       int port = 1935;


       public MyRTMPClientUploader() {
               super();

               logger.debug("connecting, host: " + host + ", app: " + app + ", port: " +
port);
               connect(host, port, app, this);
               logger.debug("done.");
       }

       @Override
       public void connectionClosed(RTMPConnection conn, RTMP state) {
               logger.debug("connection closed");
               super.connectionClosed(conn, state);
               System.exit(0);
       }

       @Override
       public void createStream(IPendingServiceCallback callback) {
               super.createStream(callback);
               logger.debug("create stream");
               //invoke("createStream", this);
       }


       @Override
       public void dispatchEvent(IEvent eve) {
               logger.debug("dispatchEvent : " + eve);

       }



       @Override
       public void onStreamEvent(Notify notify) {
               logger.debug("onStreamEvent - " + notify);



               if (notify.getCall().getServiceMethodName().equals("onStatus")) {

                       ObjectMap<String, String> map = (ObjectMap)
notify.getCall().getArguments()[0];
                       String code = (String) map.get("code");
                       String description = (String) map.get("description");
                       String details = (String) map.get("details");


                       if (StatusCodes.NS_PUBLISH_START.equals(code)) {
                               log.debug("{} for {}", new Object[]{code,details});

                               FLVService service = new FLVService();
                               service.setSerializer(new Serializer());
                               service.setDeserializer(new Deserializer());

                               log.info("Started Publishing");

                           // Read In File And Publish The Data !!
                               try {

                                               File f = new
File("C:/Sviluppo/Workspace/MMAWeb/teststreams/earth.flv");
                                               log.debug("test: {}", f);

                                               IFLV flv = (IFLV) service.getStreamableFile(f);
                                               flv.setCache(NoCacheImpl.getInstance());

                                               ITagReader reader = flv.getReader();

                                               FileStreamSource src = new FileStreamSource(reader);

                                               while (src.hasMore())
                                               {
                                                       IRTMPEvent event = src.dequeue();
                                                       RTMPMessage rtmpMsg = new RTMPMessage();
                                               rtmpMsg.setBody(event);

                                               publishStreamData(streamId, rtmpMsg);
                                               }
                                               System.out.println("\nEND!!!!!!!!!!");


                                               disconnect();
                                               //deleteStream(streamId, this);
                                               //unpublish(streamId);

                               } catch (Exception ex) {
                                       log.error(ex.getCause().toString());
                               }
                       }

                       if (StatusCodes.NS_PLAY_STOP.equals(code)) {
                               logger.debug("onStatus code == NetStream.Play.Stop, disconnecting");
                               disconnect();
                       }
               }

       }




       @Override
       synchronized public void resultReceived(IPendingServiceCall call) {
               logger.debug("service call result: " + call);

               Object result = call.getResult();

               if (result instanceof ObjectMap) {
                       if ("connect".equals(call.getServiceMethodName())) {
                               log.info("Connected");
                               createStream(this);
                       }
               }
               else {
                       if ("createStream".equals(call.getServiceMethodName())) {
                               if (result instanceof Integer) {
                                       Integer streamIdInt = (Integer) result;
                                       streamId = streamIdInt.intValue();
                                       log.debug("createStream result stream id: " + streamId);
                                       publish(streamId, "testgio2", "live", this);
                                       log.debug("published stream: " + streamId);
                               } else {
                                       log.debug("DISCONNECT!!!!!");
                                       disconnect();
                               }
                       }
               }
       }





       /**
        * MAIN
        * @param args
        */
       public static void main(String[] args) {

               new MyRTMPClientUploader();

       }
}


It seems to do somethings and seems end without errors but i can't find any
video if I open ofla_demo application.

Can someone help me?

Debug :


18:24:41.078 [main] DEBUG test.MyRTMPClientUploader - connecting, host:
localhost, app: oflaDemo, port: 8088
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect
server: localhost port 8088 application oflaDemo connectCallback
test.MyRTMPClientUploader@131f71a
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect
server: localhost port 8088 connectionParams {objectEncoding=0,
app=oflaDemo, flashVer=WIN 9,0,115,0, fpad=false,
tcUrl=rtmp://localhost:8088/oflaDemo, audioCodecs=1639, videoFunction=1,
pageUrl=null, path=oflaDemo, capabilities=15, swfUrl=null, videoCodecs=252}
connectCallback test.MyRTMPClientUploader@131f71a conectCallArguments null
18:24:41.140 [main] DEBUG test.MyRTMPClientUploader - done.
18:24:41.156 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPMinaIoHandler - Session created
18:24:41.171 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Creating connection, class:
org.red5.server.net.rtmp.RTMPMinaConnection
18:24:41.187 [SocketConnectorIoProcessor-0.0] INFO
o.r.s.net.rtmp.RTMPMinaConnection - RTMPMinaConnection created
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Connection id set 0
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Connection added to the map
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.server.net.rtmp.RTMPConnection - Set state:
org.red5.server.net.rtmp.codec.RTMP@21b6d
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.a.m.filter.executor.ExecutorFilter - Launching thread for
localhost/127.0.0.1:8088
18:24:41.187 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] OPENED
18:24:41.187 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler -
Handshake 1st phase
18:24:41.328 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] WRITE: DirectBuffer[pos=0 lim=1537 cap=2048: 03
01 86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70
0E D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B
0E B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC
F8 84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E
77 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7
7B F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35
51 03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2
15 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A
59 09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3
00 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52
03 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12
0B 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E
A1 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB
1C 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75
1F B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07
9D 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5
78 E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03
37 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE
57 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF
D7 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2
49 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32
16 11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A
13 03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0
4C 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98
83 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF
9C C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85
56 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8
D9 8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC
CE 1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0
EC 53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68
B7 DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D
BD FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D
5F D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9
52 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26
4C 5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35
19 59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B
79 38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40
4A ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F
10 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB
DE DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E
9D 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94
75 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA
F4 19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9
C5 1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D
77 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15
D5 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2
27 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11
6C 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A
5B 1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA
BE B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF
0B DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16
B2 90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D
FD DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70
CE 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3
C4 12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7
45 A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B
F5 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B
2B AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96
50 07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69
89 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75
85 2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB
9C CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] SENT: DirectBuffer[pos=0 lim=1537 cap=2048: 03 01
86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70 0E
D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B 0E
B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC F8
84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E 77
67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7 7B
F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35 51
03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2 15
10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A 59
09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3 00
3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52 03
01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12 0B
04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E A1
03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB 1C
2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75 1F
B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07 9D
93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5 78
E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03 37
8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE 57
C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF D7
33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2 49
E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32 16
11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A 13
03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0 4C
4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98 83
E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF 9C
C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85 56
E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8 D9
8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC CE
1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0 EC
53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68 B7
DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D BD
FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D 5F
D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9 52
94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26 4C
5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35 19
59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B 79
38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40 4A
ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F 10
3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB DE
DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E 9D
50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94 75
E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA F4
19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9 C5
1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D 77
36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15 D5
5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2 27
73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11 6C
03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A 5B
1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA BE
B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF 0B
DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16 B2
90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D FD
DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70 CE
34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3 C4
12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7 45
A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B F5
11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B 2B
AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96 50
07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69 89
F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75 85
2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB 9C
CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler -
messageSent
18:24:41.343 [AnonymousIoService-1] DEBUG
o.r.server.net.rtmp.BaseRTMPHandler - Message sent
18:24:41.343 [AnonymousIoService-1] DEBUG
o.a.m.filter.executor.ExecutorFilter - Exiting since queue is empty for
localhost/127.0.0.1:8088
18:25:41.375 [SocketConnectorIoProcessor-0.0] DEBUG
o.a.m.filter.executor.ExecutorFilter - Launching thread for
localhost/127.0.0.1:8088
18:25:41.375 [AnonymousIoService-2] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] CLOSED
18:25:41.375 [AnonymousIoService-2] DEBUG test.MyRTMPClientUploader -
connection closed
18:25:41.375 [AnonymousIoService-2] DEBUG
o.r.s.net.rtmp.BaseRTMPClientHandler - connectionClosed
18:25:41.375 [AnonymousIoService-2] DEBUG org.red5.server.BaseConnection -
Close, not connected nothing to do.
18:25:41.406 [AnonymousIoService-2] DEBUG org.red5.server.jmx.JMXAgent -
leaving unregisterMBean...


Any one help me?

Thank you in advance,

Parthiv
--
View this message in context: http://www.nabble.com/RTMP-java-Client-for-video-publishing-tp20939125p23540327.html
Sent from the Red5 - English mailing list archive at Nabble.com.


_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

--
Regards,
Parthiv Jani


_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

[Manuel Raña]

Sorry, i have little experience with RTMPClient.
Hopefully others will answer your question

BTW the folder is oflaDemo/streams

2009/5/14 parthiv jani <janiparthiv@...>

Hi,

i have done this but still i am not getting video in oflademo folder

and getting the same debug.

Do you think i need to check any other configurations.

On Thu, May 14, 2009 at 7:29 PM, Manuel Raña <info@...> wrote:

Change:

publish(streamId, "testgio2", "live", this);

by

publish(streamId, "testgio2", "record", this);

???

2009/5/14 janiparthiv <janiparthiv@...>

Hi all,

I'm trying to use this program with red5 version 8 but am getting following
debug and not getting video in oflaDemo folder.


import java.io.File;

import org.red5.io.ITagReader;
import org.red5.io.flv.IFLV;
import org.red5.io.flv.impl.FLVService;
import org.red5.io.object.Deserializer;
import org.red5.io.object.Serializer;
import org.red5.io.utils.ObjectMap;
import org.red5.server.api.event.IEvent;
import org.red5.server.api.event.IEventDispatcher;
import org.red5.server.api.service.IPendingServiceCall;
import org.red5.server.api.service.IPendingServiceCallback;
import org.red5.server.cache.NoCacheImpl;
import org.red5.server.net.rtmp.RTMPClient;
import org.red5.server.net.rtmp.RTMPConnection;
import org.red5.server.net.rtmp.RTMPClient.INetStreamEventHandler;
import org.red5.server.net.rtmp.codec.RTMP;
import org.red5.server.net.rtmp.event.IRTMPEvent;
import org.red5.server.net.rtmp.event.Notify;
import org.red5.server.net.rtmp.status.StatusCodes;
import org.red5.server.stream.FileStreamSource;
import org.red5.server.stream.message.RTMPMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyRTMPClientUploader extends RTMPClient implements
INetStreamEventHandler, IPendingServiceCallback, IEventDispatcher
{

       private static final Logger logger =
LoggerFactory.getLogger(MyRTMPClientUploader.class);

       private int streamId;
       String host = "localhost";
       String app = "oflaDemo";
       int port = 1935;


       public MyRTMPClientUploader() {
               super();

               logger.debug("connecting, host: " + host + ", app: " + app + ", port: " +
port);
               connect(host, port, app, this);
               logger.debug("done.");
       }

       @Override
       public void connectionClosed(RTMPConnection conn, RTMP state) {
               logger.debug("connection closed");
               super.connectionClosed(conn, state);
               System.exit(0);
       }

       @Override
       public void createStream(IPendingServiceCallback callback) {
               super.createStream(callback);
               logger.debug("create stream");
               //invoke("createStream", this);
       }


       @Override
       public void dispatchEvent(IEvent eve) {
               logger.debug("dispatchEvent : " + eve);

       }



       @Override
       public void onStreamEvent(Notify notify) {
               logger.debug("onStreamEvent - " + notify);



               if (notify.getCall().getServiceMethodName().equals("onStatus")) {

                       ObjectMap<String, String> map = (ObjectMap)
notify.getCall().getArguments()[0];
                       String code = (String) map.get("code");
                       String description = (String) map.get("description");
                       String details = (String) map.get("details");


                       if (StatusCodes.NS_PUBLISH_START.equals(code)) {
                               log.debug("{} for {}", new Object[]{code,details});

                               FLVService service = new FLVService();
                               service.setSerializer(new Serializer());
                               service.setDeserializer(new Deserializer());

                               log.info("Started Publishing");

                           // Read In File And Publish The Data !!
                               try {

                                               File f = new
File("C:/Sviluppo/Workspace/MMAWeb/teststreams/earth.flv");
                                               log.debug("test: {}", f);

                                               IFLV flv = (IFLV) service.getStreamableFile(f);
                                               flv.setCache(NoCacheImpl.getInstance());

                                               ITagReader reader = flv.getReader();

                                               FileStreamSource src = new FileStreamSource(reader);

                                               while (src.hasMore())
                                               {
                                                       IRTMPEvent event = src.dequeue();
                                                       RTMPMessage rtmpMsg = new RTMPMessage();
                                               rtmpMsg.setBody(event);

                                               publishStreamData(streamId, rtmpMsg);
                                               }
                                               System.out.println("\nEND!!!!!!!!!!");


                                               disconnect();
                                               //deleteStream(streamId, this);
                                               //unpublish(streamId);

                               } catch (Exception ex) {
                                       log.error(ex.getCause().toString());
                               }
                       }

                       if (StatusCodes.NS_PLAY_STOP.equals(code)) {
                               logger.debug("onStatus code == NetStream.Play.Stop, disconnecting");
                               disconnect();
                       }
               }

       }




       @Override
       synchronized public void resultReceived(IPendingServiceCall call) {
               logger.debug("service call result: " + call);

               Object result = call.getResult();

               if (result instanceof ObjectMap) {
                       if ("connect".equals(call.getServiceMethodName())) {
                               log.info("Connected");
                               createStream(this);
                       }
               }
               else {
                       if ("createStream".equals(call.getServiceMethodName())) {
                               if (result instanceof Integer) {
                                       Integer streamIdInt = (Integer) result;
                                       streamId = streamIdInt.intValue();
                                       log.debug("createStream result stream id: " + streamId);
                                       publish(streamId, "testgio2", "live", this);
                                       log.debug("published stream: " + streamId);
                               } else {
                                       log.debug("DISCONNECT!!!!!");
                                       disconnect();
                               }
                       }
               }
       }





       /**
        * MAIN
        * @param args
        */
       public static void main(String[] args) {

               new MyRTMPClientUploader();

       }
}


It seems to do somethings and seems end without errors but i can't find any
video if I open ofla_demo application.

Can someone help me?

Debug :


18:24:41.078 [main] DEBUG test.MyRTMPClientUploader - connecting, host:
localhost, app: oflaDemo, port: 8088
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect
server: localhost port 8088 application oflaDemo connectCallback
test.MyRTMPClientUploader@131f71a
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect
server: localhost port 8088 connectionParams {objectEncoding=0,
app=oflaDemo, flashVer=WIN 9,0,115,0, fpad=false,
tcUrl=rtmp://localhost:8088/oflaDemo, audioCodecs=1639, videoFunction=1,
pageUrl=null, path=oflaDemo, capabilities=15, swfUrl=null, videoCodecs=252}
connectCallback test.MyRTMPClientUploader@131f71a conectCallArguments null
18:24:41.140 [main] DEBUG test.MyRTMPClientUploader - done.
18:24:41.156 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPMinaIoHandler - Session created
18:24:41.171 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Creating connection, class:
org.red5.server.net.rtmp.RTMPMinaConnection
18:24:41.187 [SocketConnectorIoProcessor-0.0] INFO
o.r.s.net.rtmp.RTMPMinaConnection - RTMPMinaConnection created
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Connection id set 0
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Connection added to the map
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.server.net.rtmp.RTMPConnection - Set state:
org.red5.server.net.rtmp.codec.RTMP@21b6d
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.a.m.filter.executor.ExecutorFilter - Launching thread for
localhost/127.0.0.1:8088
18:24:41.187 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] OPENED
18:24:41.187 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler -
Handshake 1st phase
18:24:41.328 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] WRITE: DirectBuffer[pos=0 lim=1537 cap=2048: 03
01 86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70
0E D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B
0E B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC
F8 84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E
77 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7
7B F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35
51 03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2
15 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A
59 09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3
00 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52
03 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12
0B 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E
A1 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB
1C 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75
1F B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07
9D 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5
78 E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03
37 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE
57 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF
D7 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2
49 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32
16 11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A
13 03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0
4C 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98
83 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF
9C C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85
56 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8
D9 8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC
CE 1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0
EC 53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68
B7 DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D
BD FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D
5F D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9
52 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26
4C 5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35
19 59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B
79 38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40
4A ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F
10 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB
DE DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E
9D 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94
75 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA
F4 19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9
C5 1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D
77 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15
D5 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2
27 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11
6C 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A
5B 1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA
BE B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF
0B DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16
B2 90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D
FD DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70
CE 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3
C4 12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7
45 A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B
F5 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B
2B AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96
50 07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69
89 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75
85 2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB
9C CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] SENT: DirectBuffer[pos=0 lim=1537 cap=2048: 03 01
86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70 0E
D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B 0E
B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC F8
84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E 77
67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7 7B
F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35 51
03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2 15
10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A 59
09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3 00
3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52 03
01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12 0B
04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E A1
03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB 1C
2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75 1F
B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07 9D
93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5 78
E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03 37
8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE 57
C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF D7
33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2 49
E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32 16
11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A 13
03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0 4C
4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98 83
E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF 9C
C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85 56
E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8 D9
8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC CE
1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0 EC
53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68 B7
DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D BD
FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D 5F
D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9 52
94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26 4C
5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35 19
59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B 79
38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40 4A
ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F 10
3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB DE
DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E 9D
50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94 75
E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA F4
19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9 C5
1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D 77
36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15 D5
5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2 27
73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11 6C
03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A 5B
1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA BE
B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF 0B
DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16 B2
90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D FD
DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70 CE
34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3 C4
12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7 45
A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B F5
11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B 2B
AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96 50
07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69 89
F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75 85
2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB 9C
CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler -
messageSent
18:24:41.343 [AnonymousIoService-1] DEBUG
o.r.server.net.rtmp.BaseRTMPHandler - Message sent
18:24:41.343 [AnonymousIoService-1] DEBUG
o.a.m.filter.executor.ExecutorFilter - Exiting since queue is empty for
localhost/127.0.0.1:8088
18:25:41.375 [SocketConnectorIoProcessor-0.0] DEBUG
o.a.m.filter.executor.ExecutorFilter - Launching thread for
localhost/127.0.0.1:8088
18:25:41.375 [AnonymousIoService-2] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] CLOSED
18:25:41.375 [AnonymousIoService-2] DEBUG test.MyRTMPClientUploader -
connection closed
18:25:41.375 [AnonymousIoService-2] DEBUG
o.r.s.net.rtmp.BaseRTMPClientHandler - connectionClosed
18:25:41.375 [AnonymousIoService-2] DEBUG org.red5.server.BaseConnection -
Close, not connected nothing to do.
18:25:41.406 [AnonymousIoService-2] DEBUG org.red5.server.jmx.JMXAgent -
leaving unregisterMBean...


Any one help me?

Thank you in advance,

Parthiv
--
View this message in context: http://www.nabble.com/RTMP-java-Client-for-video-publishing-tp20939125p23540327.html
Sent from the Red5 - English mailing list archive at Nabble.com.


_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

--
Regards,
Parthiv Jani


_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

[janiparthiv]

yes i know the folder is oflaDemo/streams

Thank you v.much for your reply.

On Thu, May 14, 2009 at 7:42 PM, Manuel Raña <info@...> wrote:

Sorry, i have little experience with RTMPClient.
Hopefully others will answer your question

BTW the folder is oflaDemo/streams

2009/5/14 parthiv jani <janiparthiv@...>

Hi,

i have done this but still i am not getting video in oflademo folder

and getting the same debug.

Do you think i need to check any other configurations.

On Thu, May 14, 2009 at 7:29 PM, Manuel Raña <info@...> wrote:

Change:

publish(streamId, "testgio2", "live", this);

by

publish(streamId, "testgio2", "record", this);

???

2009/5/14 janiparthiv <janiparthiv@...>

Hi all,

I'm trying to use this program with red5 version 8 but am getting following
debug and not getting video in oflaDemo folder.


import java.io.File;

import org.red5.io.ITagReader;
import org.red5.io.flv.IFLV;
import org.red5.io.flv.impl.FLVService;
import org.red5.io.object.Deserializer;
import org.red5.io.object.Serializer;
import org.red5.io.utils.ObjectMap;
import org.red5.server.api.event.IEvent;
import org.red5.server.api.event.IEventDispatcher;
import org.red5.server.api.service.IPendingServiceCall;
import org.red5.server.api.service.IPendingServiceCallback;
import org.red5.server.cache.NoCacheImpl;
import org.red5.server.net.rtmp.RTMPClient;
import org.red5.server.net.rtmp.RTMPConnection;
import org.red5.server.net.rtmp.RTMPClient.INetStreamEventHandler;
import org.red5.server.net.rtmp.codec.RTMP;
import org.red5.server.net.rtmp.event.IRTMPEvent;
import org.red5.server.net.rtmp.event.Notify;
import org.red5.server.net.rtmp.status.StatusCodes;
import org.red5.server.stream.FileStreamSource;
import org.red5.server.stream.message.RTMPMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyRTMPClientUploader extends RTMPClient implements
INetStreamEventHandler, IPendingServiceCallback, IEventDispatcher
{

       private static final Logger logger =
LoggerFactory.getLogger(MyRTMPClientUploader.class);

       private int streamId;
       String host = "localhost";
       String app = "oflaDemo";
       int port = 1935;


       public MyRTMPClientUploader() {
               super();

               logger.debug("connecting, host: " + host + ", app: " + app + ", port: " +
port);
               connect(host, port, app, this);
               logger.debug("done.");
       }

       @Override
       public void connectionClosed(RTMPConnection conn, RTMP state) {
               logger.debug("connection closed");
               super.connectionClosed(conn, state);
               System.exit(0);
       }

       @Override
       public void createStream(IPendingServiceCallback callback) {
               super.createStream(callback);
               logger.debug("create stream");
               //invoke("createStream", this);
       }


       @Override
       public void dispatchEvent(IEvent eve) {
               logger.debug("dispatchEvent : " + eve);

       }



       @Override
       public void onStreamEvent(Notify notify) {
               logger.debug("onStreamEvent - " + notify);



               if (notify.getCall().getServiceMethodName().equals("onStatus")) {

                       ObjectMap<String, String> map = (ObjectMap)
notify.getCall().getArguments()[0];
                       String code = (String) map.get("code");
                       String description = (String) map.get("description");
                       String details = (String) map.get("details");


                       if (StatusCodes.NS_PUBLISH_START.equals(code)) {
                               log.debug("{} for {}", new Object[]{code,details});

                               FLVService service = new FLVService();
                               service.setSerializer(new Serializer());
                               service.setDeserializer(new Deserializer());

                               log.info("Started Publishing");

                           // Read In File And Publish The Data !!
                               try {

                                               File f = new
File("C:/Sviluppo/Workspace/MMAWeb/teststreams/earth.flv");
                                               log.debug("test: {}", f);

                                               IFLV flv = (IFLV) service.getStreamableFile(f);
                                               flv.setCache(NoCacheImpl.getInstance());

                                               ITagReader reader = flv.getReader();

                                               FileStreamSource src = new FileStreamSource(reader);

                                               while (src.hasMore())
                                               {
                                                       IRTMPEvent event = src.dequeue();
                                                       RTMPMessage rtmpMsg = new RTMPMessage();
                                               rtmpMsg.setBody(event);

                                               publishStreamData(streamId, rtmpMsg);
                                               }
                                               System.out.println("\nEND!!!!!!!!!!");


                                               disconnect();
                                               //deleteStream(streamId, this);
                                               //unpublish(streamId);

                               } catch (Exception ex) {
                                       log.error(ex.getCause().toString());
                               }
                       }

                       if (StatusCodes.NS_PLAY_STOP.equals(code)) {
                               logger.debug("onStatus code == NetStream.Play.Stop, disconnecting");
                               disconnect();
                       }
               }

       }




       @Override
       synchronized public void resultReceived(IPendingServiceCall call) {
               logger.debug("service call result: " + call);

               Object result = call.getResult();

               if (result instanceof ObjectMap) {
                       if ("connect".equals(call.getServiceMethodName())) {
                               log.info("Connected");
                               createStream(this);
                       }
               }
               else {
                       if ("createStream".equals(call.getServiceMethodName())) {
                               if (result instanceof Integer) {
                                       Integer streamIdInt = (Integer) result;
                                       streamId = streamIdInt.intValue();
                                       log.debug("createStream result stream id: " + streamId);
                                       publish(streamId, "testgio2", "live", this);
                                       log.debug("published stream: " + streamId);
                               } else {
                                       log.debug("DISCONNECT!!!!!");
                                       disconnect();
                               }
                       }
               }
       }





       /**
        * MAIN
        * @param args
        */
       public static void main(String[] args) {

               new MyRTMPClientUploader();

       }
}


It seems to do somethings and seems end without errors but i can't find any
video if I open ofla_demo application.

Can someone help me?

Debug :


18:24:41.078 [main] DEBUG test.MyRTMPClientUploader - connecting, host:
localhost, app: oflaDemo, port: 8088
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect
server: localhost port 8088 application oflaDemo connectCallback
test.MyRTMPClientUploader@131f71a
18:24:41.078 [main] DEBUG o.r.s.net.rtmp.BaseRTMPClientHandler - connect
server: localhost port 8088 connectionParams {objectEncoding=0,
app=oflaDemo, flashVer=WIN 9,0,115,0, fpad=false,
tcUrl=rtmp://localhost:8088/oflaDemo, audioCodecs=1639, videoFunction=1,
pageUrl=null, path=oflaDemo, capabilities=15, swfUrl=null, videoCodecs=252}
connectCallback test.MyRTMPClientUploader@131f71a conectCallArguments null
18:24:41.140 [main] DEBUG test.MyRTMPClientUploader - done.
18:24:41.156 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPMinaIoHandler - Session created
18:24:41.171 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Creating connection, class:
org.red5.server.net.rtmp.RTMPMinaConnection
18:24:41.187 [SocketConnectorIoProcessor-0.0] INFO
o.r.s.net.rtmp.RTMPMinaConnection - RTMPMinaConnection created
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Connection id set 0
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.s.net.rtmp.RTMPClientConnManager - Connection added to the map
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.r.server.net.rtmp.RTMPConnection - Set state:
org.red5.server.net.rtmp.codec.RTMP@21b6d
18:24:41.187 [SocketConnectorIoProcessor-0.0] DEBUG
o.a.m.filter.executor.ExecutorFilter - Launching thread for
localhost/127.0.0.1:8088
18:24:41.187 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] OPENED
18:24:41.187 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler -
Handshake 1st phase
18:24:41.328 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] WRITE: DirectBuffer[pos=0 lim=1537 cap=2048: 03
01 86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70
0E D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B
0E B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC
F8 84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E
77 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7
7B F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35
51 03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2
15 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A
59 09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3
00 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52
03 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12
0B 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E
A1 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB
1C 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75
1F B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07
9D 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5
78 E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03
37 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE
57 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF
D7 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2
49 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32
16 11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A
13 03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0
4C 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98
83 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF
9C C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85
56 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8
D9 8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC
CE 1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0
EC 53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68
B7 DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D
BD FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D
5F D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9
52 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26
4C 5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35
19 59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B
79 38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40
4A ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F
10 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB
DE DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E
9D 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94
75 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA
F4 19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9
C5 1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D
77 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15
D5 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2
27 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11
6C 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A
5B 1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA
BE B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF
0B DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16
B2 90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D
FD DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70
CE 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3
C4 12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7
45 A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B
F5 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B
2B AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96
50 07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69
89 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75
85 2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB
9C CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] SENT: DirectBuffer[pos=0 lim=1537 cap=2048: 03 01
86 4F 7F 00 00 00 00 6B 04 67 52 A2 70 5B 51 A2 89 CA CC 8E 70 F0 06 70 0E
D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F F5 4F EC D0 2F 46 2B 76 10 92 1B 0E
B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB 53 B9 10 4D EA C1 E7 7B 70 DE DC F8
84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E 77
67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7 7B
F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35 51
03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2 15
10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A 59
09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3 00
3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52 03
01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B 74 BD D9 97 63 EF FA A3 D9 21 12 0B
04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF CA B4 48 1E 82 50 90 94 37 24 7E A1
03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E 26 6C 63 72 8D B7 7C B8 21 8F BB 1C
2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75 1F
B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE 90 AB 77 28 BF C0 E0 63 AF D9 07 9D
93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5 78
E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80 6A F0 50 CC DE 4C 44 41 74 3D 03 37
8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE 57
C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04 4C 0E E0 52 93 9A EC ED F3 F7 EF D7
33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94 49 72 03 F3 CF 15 31 BC B5 68 C2 49
E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49 0E 7F 25 EB D1 81 81 C0 A7 49 32 16
11 31 59 12 43 D3 A6 95 4A C5 FE DF 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A 13
03 D3 10 71 0B C0 1E CF DB AA CC A6 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0 4C
4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98 83
E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF 9C
C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85 56
E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0 17 C0 5B 09 86 07 FA 69 DA 65 B8 D9
8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F 83 77 BD A1 A1 76 28 9C 0F CC DC CE
1F 16 02 47 98 37 96 87 B1 70 3A EA A4 65 77 98 12 27 23 47 A8 1B 79 C0 EC
53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C AF C6 BF 1F D1 40 DC 28 81 34 68 B7
DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D BD
FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D 5F
D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9 52
94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64 89 51 80 7B 1F 02 77 81 FA E9 26 4C
5F E2 0D 05 55 EE 71 71 FC 35 33 22 63 F5 36 45 F6 2F D0 13 B7 58 4F 35 19
59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B 79
38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF 3D 0D 68 7E D8 80 7B 07 23 CE 40 4A
ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F 10
3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C 71 73 A0 58 90 54 A8 1C 31 20 DB DE
DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E 9D
50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA 6C 02 DA 27 29 6E E9 54 41 A4 94 75
E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA F4
19 77 C4 65 D6 18 3E 60 08 74 49 BA C8 86 37 8A 0F 79 91 53 20 23 00 B9 C5
1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4 53 35 18 DE 20 1F AA E2 40 0D 6D 77
36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8 44 8E AE 9C D7 97 6A 99 EE 40 15 D5
5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2 76 8B 49 6D 66 83 5F BE 05 8E F2 27
73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70 ED 33 CE 31 9D 9F 95 80 9E 73 11 6C
03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A 5B
1A B6 19 57 99 09 E8 EC 82 DC 06 39 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA BE
B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF 0B
DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12 99 96 96 A5 34 5A 2C 7C F6 BC 16 B2
90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D FD
DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1 C8 FC 12 9A FC DA FD 2A C2 7F 70 CE
34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3 C4
12 46 CF 06 FE 0F 82 82 74 00 71 F8 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7 45
A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B F5
11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B 2B
AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96 50
07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69 89
F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75 85
2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7 10 FE DB 54 34 FB 91 24 1C 07 FB 9C
CE D0 46 CF C4 9D 09 49 24 EC]
18:24:41.343 [AnonymousIoService-1] DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler -
messageSent
18:24:41.343 [AnonymousIoService-1] DEBUG
o.r.server.net.rtmp.BaseRTMPHandler - Message sent
18:24:41.343 [AnonymousIoService-1] DEBUG
o.a.m.filter.executor.ExecutorFilter - Exiting since queue is empty for
localhost/127.0.0.1:8088
18:25:41.375 [SocketConnectorIoProcessor-0.0] DEBUG
o.a.m.filter.executor.ExecutorFilter - Launching thread for
localhost/127.0.0.1:8088
18:25:41.375 [AnonymousIoService-2] INFO  o.r.s.net.rtmp.RTMPMinaIoHandler -
[localhost/127.0.0.1:8088] CLOSED
18:25:41.375 [AnonymousIoService-2] DEBUG test.MyRTMPClientUploader -
connection closed
18:25:41.375 [AnonymousIoService-2] DEBUG
o.r.s.net.rtmp.BaseRTMPClientHandler - connectionClosed
18:25:41.375 [AnonymousIoService-2] DEBUG org.red5.server.BaseConnection -
Close, not connected nothing to do.
18:25:41.406 [AnonymousIoService-2] DEBUG org.red5.server.jmx.JMXAgent -
leaving unregisterMBean...


Any one help me?

Thank you in advance,

Parthiv
--
View this message in context: http://www.nabble.com/RTMP-java-Client-for-video-publishing-tp20939125p23540327.html
Sent from the Red5 - English mailing list archive at Nabble.com.


_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

--
Regards,
Parthiv Jani


_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

--
Regards,
Parthiv Jani


_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org

[Jase-3]

Did you get this going in the end?

I was wondering how you get this working for live broadcasting with a
speex encoded stream or file

Jase


On Thu, 2009-05-14 at 19:46 +0530, parthiv jani wrote:

> yes i know the folder is oflaDemo/streams
>
> Thank you v.much for your reply.
>
> On Thu, May 14, 2009 at 7:42 PM, Manuel Raña <info@...> wrote:
>         Sorry, i have little experience with RTMPClient.
>         Hopefully others will answer your question
>        
>         BTW the folder is oflaDemo/streams
>        
>        
>        
>         2009/5/14 parthiv jani <janiparthiv@...>
>        
>        
>                 Hi,
>                
>                 i have done this but still i am not getting video in
>                 oflademo folder
>                
>                 and getting the same debug.
>                
>                 Do you think i need to check any other configurations.
>                
>                
>                
>                
>                 On Thu, May 14, 2009 at 7:29 PM, Manuel Raña
>                 <info@...> wrote:
>                         Change:
>                        
>                        
>                         publish(streamId, "testgio2", "live", this);
>                        
>                        
>                         by
>                        
>                         publish(streamId, "testgio2", "record", this);
>                        
>                         ???
>                        
>                        
>                         2009/5/14 janiparthiv <janiparthiv@...>
>                        
>                        
>                                
>                                 Hi all,
>                                
>                                 I'm trying to use this program with
>                                 red5 version 8 but am getting
>                                 following
>                                 debug and not getting video in
>                                 oflaDemo folder.
>                                
>                                
>                                 import java.io.File;
>                                
>                                 import org.red5.io.ITagReader;
>                                 import org.red5.io.flv.IFLV;
>                                 import
>                                 org.red5.io.flv.impl.FLVService;
>                                 import
>                                 org.red5.io.object.Deserializer;
>                                 import org.red5.io.object.Serializer;
>                                 import org.red5.io.utils.ObjectMap;
>                                 import
>                                 org.red5.server.api.event.IEvent;
>                                 import
>                                 org.red5.server.api.event.IEventDispatcher;
>                                 import
>                                 org.red5.server.api.service.IPendingServiceCall;
>                                 import
>                                 org.red5.server.api.service.IPendingServiceCallback;
>                                 import
>                                 org.red5.server.cache.NoCacheImpl;
>                                 import
>                                 org.red5.server.net.rtmp.RTMPClient;
>                                 import
>                                 org.red5.server.net.rtmp.RTMPConnection;
>                                 import
>                                 org.red5.server.net.rtmp.RTMPClient.INetStreamEventHandler;
>                                 import
>                                 org.red5.server.net.rtmp.codec.RTMP;
>                                 import
>                                 org.red5.server.net.rtmp.event.IRTMPEvent;
>                                 import
>                                 org.red5.server.net.rtmp.event.Notify;
>                                 import
>                                 org.red5.server.net.rtmp.status.StatusCodes;
>                                 import
>                                 org.red5.server.stream.FileStreamSource;
>                                 import
>                                 org.red5.server.stream.message.RTMPMessage;
>                                 import org.slf4j.Logger;
>                                 import org.slf4j.LoggerFactory;
>                                
>                                 public class MyRTMPClientUploader
>                                 extends RTMPClient implements
>                                 INetStreamEventHandler,
>                                 IPendingServiceCallback,
>                                 IEventDispatcher
>                                 {
>                                
>                                        private static final Logger
>                                 logger =
>                                 LoggerFactory.getLogger(MyRTMPClientUploader.class);
>                                
>                                        private int streamId;
>                                        String host = "localhost";
>                                        String app = "oflaDemo";
>                                        int port = 1935;
>                                
>                                
>                                        public MyRTMPClientUploader() {
>                                                super();
>                                
>                                
>                                  logger.debug("connecting, host: " +
>                                 host + ", app: " + app + ", port: " +
>                                 port);
>                                                connect(host, port,
>                                 app, this);
>                                                logger.debug("done.");
>                                        }
>                                
>                                        @Override
>                                        public void
>                                 connectionClosed(RTMPConnection conn,
>                                 RTMP state) {
>                                
>                                  logger.debug("connection closed");
>                                
>                                  super.connectionClosed(conn, state);
>                                                System.exit(0);
>                                        }
>                                
>                                        @Override
>                                        public void
>                                 createStream(IPendingServiceCallback
>                                 callback) {
>                                
>                                  super.createStream(callback);
>                                                logger.debug("create
>                                 stream");
>                                
>                                  //invoke("createStream", this);
>                                        }
>                                
>                                
>                                        @Override
>                                        public void
>                                 dispatchEvent(IEvent eve) {
>                                
>                                  logger.debug("dispatchEvent : " +
>                                 eve);
>                                
>                                        }
>                                
>                                
>                                
>                                        @Override
>                                        public void
>                                 onStreamEvent(Notify notify) {
>                                
>                                  logger.debug("onStreamEvent - " +
>                                 notify);
>                                
>                                
>                                
>                                                if
>                                 (notify.getCall().getServiceMethodName().equals("onStatus")) {
>                                
>                                
>                                  ObjectMap<String, String> map =
>                                 (ObjectMap)
>                                 notify.getCall().getArguments()[0];
>                                                        String code =
>                                 (String) map.get("code");
>                                                        String
>                                 description = (String)
>                                 map.get("description");
>                                                        String details
>                                 = (String) map.get("details");
>                                
>                                
>                                                        if
>                                 (StatusCodes.NS_PUBLISH_START.equals(code)) {
>                                
>                                  log.debug("{} for {}", new
>                                 Object[]{code,details});
>                                
>                                
>                                  FLVService service = new
>                                 FLVService();
>                                
>                                  service.setSerializer(new
>                                 Serializer());
>                                
>                                  service.setDeserializer(new
>                                 Deserializer());
>                                
>                                
>                                  log.info("Started Publishing");
>                                
>                                                            // Read In
>                                 File And Publish The Data !!
>                                                                try {
>                                
>                                
>                                          File f = new
>                                 File("C:/Sviluppo/Workspace/MMAWeb/teststreams/earth.flv");
>                                
>                                          log.debug("test: {}", f);
>                                
>                                
>                                          IFLV flv = (IFLV)
>                                 service.getStreamableFile(f);
>                                
>                                
>                                  flv.setCache(NoCacheImpl.getInstance());
>                                
>                                
>                                          ITagReader reader =
>                                 flv.getReader();
>                                
>                                
>                                          FileStreamSource src = new
>                                 FileStreamSource(reader);
>                                
>                                
>                                          while (src.hasMore())
>                                
>                                          {
>                                
>                                                  IRTMPEvent event =
>                                 src.dequeue();
>                                
>                                                  RTMPMessage rtmpMsg =
>                                 new RTMPMessage();
>                                
>                                          rtmpMsg.setBody(event);
>                                
>                                
>                                          publishStreamData(streamId,
>                                 rtmpMsg);
>                                
>                                          }
>                                
>                                
>                                  System.out.println("\nEND!!!!!!!!!!");
>                                
>                                
>                                
>                                          disconnect();
>                                
>                                          //deleteStream(streamId,
>                                 this);
>                                
>                                          //unpublish(streamId);
>                                
>                                                                } catch
>                                 (Exception ex) {
>                                
>                                  log.error(ex.getCause().toString());
>                                                                }
>                                                        }
>                                
>                                                        if
>                                 (StatusCodes.NS_PLAY_STOP.equals(code)) {
>                                
>                                  logger.debug("onStatus code ==
>                                 NetStream.Play.Stop, disconnecting");
>                                
>                                  disconnect();
>                                                        }
>                                                }
>                                
>                                        }
>                                
>                                
>                                
>                                
>                                        @Override
>                                        synchronized public void
>                                 resultReceived(IPendingServiceCall
>                                 call) {
>                                                logger.debug("service
>                                 call result: " + call);
>                                
>                                                Object result =
>                                 call.getResult();
>                                
>                                                if (result instanceof
>                                 ObjectMap) {
>                                                        if
>                                 ("connect".equals(call.getServiceMethodName())) {
>                                
>                                  log.info("Connected");
>                                
>                                  createStream(this);
>                                                        }
>                                                }
>                                                else {
>                                                        if
>                                 ("createStream".equals(call.getServiceMethodName())) {
>                                                                if
>                                 (result instanceof Integer) {
>                                
>                                  Integer streamIdInt = (Integer)
>                                 result;
>                                
>                                  streamId = streamIdInt.intValue();
>                                
>                                  log.debug("createStream result stream
>                                 id: " + streamId);
>                                
>                                  publish(streamId, "testgio2", "live",
>                                 this);
>                                
>                                  log.debug("published stream: " +
>                                 streamId);
>                                                                } else
>                                 {
>                                
>                                  log.debug("DISCONNECT!!!!!");
>                                
>                                  disconnect();
>                                                                }
>                                                        }
>                                                }
>                                        }
>                                
>                                
>                                
>                                
>                                
>                                        /**
>                                         * MAIN
>                                         * @param args
>                                         */
>                                        public static void
>                                 main(String[] args) {
>                                
>                                                new
>                                 MyRTMPClientUploader();
>                                
>                                        }
>                                 }
>                                
>                                
>                                 It seems to do somethings and seems
>                                 end without errors but i can't find
>                                 any
>                                 video if I open ofla_demo application.
>                                
>                                 Can someone help me?
>                                
>                                 Debug :
>                                
>                                
>                                 18:24:41.078 [main] DEBUG
>                                 test.MyRTMPClientUploader -
>                                 connecting, host:
>                                 localhost, app: oflaDemo, port: 8088
>                                 18:24:41.078 [main] DEBUG
>                                 o.r.s.net.rtmp.BaseRTMPClientHandler -
>                                 connect
>                                 server: localhost port 8088
>                                 application oflaDemo connectCallback
>                                 test.MyRTMPClientUploader@131f71a
>                                 18:24:41.078 [main] DEBUG
>                                 o.r.s.net.rtmp.BaseRTMPClientHandler -
>                                 connect
>                                 server: localhost port 8088
>                                 connectionParams {objectEncoding=0,
>                                 app=oflaDemo, flashVer=WIN 9,0,115,0,
>                                 fpad=false,
>                                 tcUrl=rtmp://localhost:8088/oflaDemo,
>                                 audioCodecs=1639, videoFunction=1,
>                                 pageUrl=null, path=oflaDemo,
>                                 capabilities=15, swfUrl=null,
>                                 videoCodecs=252}
>                                 connectCallback
>                                 test.MyRTMPClientUploader@131f71a
>                                 conectCallArguments null
>                                 18:24:41.140 [main] DEBUG
>                                 test.MyRTMPClientUploader - done.
>                                 18:24:41.156
>                                 [SocketConnectorIoProcessor-0.0] DEBUG
>                                 o.r.s.net.rtmp.RTMPMinaIoHandler -
>                                 Session created
>                                 18:24:41.171
>                                 [SocketConnectorIoProcessor-0.0] DEBUG
>                                 o.r.s.net.rtmp.RTMPClientConnManager -
>                                 Creating connection, class:
>                                 org.red5.server.net.rtmp.RTMPMinaConnection
>                                 18:24:41.187
>                                 [SocketConnectorIoProcessor-0.0] INFO
>                                 o.r.s.net.rtmp.RTMPMinaConnection -
>                                 RTMPMinaConnection created
>                                 18:24:41.187
>                                 [SocketConnectorIoProcessor-0.0] DEBUG
>                                 o.r.s.net.rtmp.RTMPClientConnManager -
>                                 Connection id set 0
>                                 18:24:41.187
>                                 [SocketConnectorIoProcessor-0.0] DEBUG
>                                 o.r.s.net.rtmp.RTMPClientConnManager -
>                                 Connection added to the map
>                                 18:24:41.187
>                                 [SocketConnectorIoProcessor-0.0] DEBUG
>                                 o.r.server.net.rtmp.RTMPConnection -
>                                 Set state:
>                                 org.red5.server.net.rtmp.codec.RTMP@21b6d
>                                 18:24:41.187
>                                 [SocketConnectorIoProcessor-0.0] DEBUG
>                                 o.a.m.filter.executor.ExecutorFilter -
>                                 Launching thread for
>                                 localhost/127.0.0.1:8088
>                                 18:24:41.187 [AnonymousIoService-1]
>                                 INFO  o.r.s.net.rtmp.RTMPMinaIoHandler
>                                 -
>                                 [localhost/127.0.0.1:8088] OPENED
>                                 18:24:41.187 [AnonymousIoService-1]
>                                 DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler
>                                 -
>                                 Handshake 1st phase
>                                 18:24:41.328 [AnonymousIoService-1]
>                                 INFO  o.r.s.net.rtmp.RTMPMinaIoHandler
>                                 -
>                                 [localhost/127.0.0.1:8088] WRITE:
>                                 DirectBuffer[pos=0 lim=1537 cap=2048:
>                                 03
>                                 01 86 4F 7F 00 00 00 00 6B 04 67 52 A2
>                                 70 5B 51 A2 89 CA CC 8E 70 F0 06 70
>                                 0E D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45
>                                 0F F5 4F EC D0 2F 46 2B 76 10 92 1B
>                                 0E B6 ED 71 73 45 C1 C6 26 0C 69 59 7B
>                                 BB 53 B9 10 4D EA C1 E7 7B 70 DE DC
>                                 F8 84 90 BF 80 E8 85 B2 46 2C 78 A1 85
>                                 01 8F 8B 05 3F A1 0C 1A 78 70 8C 8E
>                                 77 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24
>                                 63 21 75 3A 5A 6F C2 A1 2D 4F 64 B7
>                                 7B F7 EF DA 45 B2 51 FD CB 74 49 FD 63
>                                 8B 88 FB DE 5A 3B AB 7F 75 25 BB 35
>                                 51 03 81 12 FF 66 02 3D 88 DC 66 A2 FB
>                                 09 24 9D 86 FD C4 00 C2 8B 6F B7 B2
>                                 15 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3
>                                 E8 3C 00 9B 26 BA B4 5F 2C 36 F3 4A
>                                 59 09 1B E5 00 9D E4 66 4D 05 66 D0 D1
>                                 D6 94 4F 64 A1 2E 8D 2F B0 06 01 B3
>                                 00 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68
>                                 DD 1C 7B FD 2E B1 8B 45 FD 5B 48 52
>                                 03 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22
>                                 8B 74 BD D9 97 63 EF FA A3 D9 21 12
>                                 0B 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A
>                                 FF CA B4 48 1E 82 50 90 94 37 24 7E
>                                 A1 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43
>                                 8E 26 6C 63 72 8D B7 7C B8 21 8F BB
>                                 1C 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46
>                                 A5 60 A9 71 41 DD 25 F5 C1 F6 BD 75
>                                 1F B0 15 E0 ED C2 4B AC F1 C8 EF A3 44
>                                 BE 90 AB 77 28 BF C0 E0 63 AF D9 07
>                                 9D 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F
>                                 3E 87 09 BE 36 D0 8F 7C 22 13 9F C5
>                                 78 E0 54 4C A7 77 3F DF 87 4A 28 7B 47
>                                 80 6A F0 50 CC DE 4C 44 41 74 3D 03
>                                 37 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22
>                                 49 2F C9 6D F1 08 C4 4F B1 91 B3 EE
>                                 57 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92
>                                 04 4C 0E E0 52 93 9A EC ED F3 F7 EF
>                                 D7 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C
>                                 94 49 72 03 F3 CF 15 31 BC B5 68 C2
>                                 49 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02
>                                 49 0E 7F 25 EB D1 81 81 C0 A7 49 32
>                                 16 11 31 59 12 43 D3 A6 95 4A C5 FE DF
>                                 14 DA A6 5A C0 D5 6A AF B3 DE 32 2A
>                                 13 03 D3 10 71 0B C0 1E CF DB AA CC A6
>                                 B5 65 2E C4 0B 5C A7 1C 8B 2D 7F C0
>                                 4C 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50
>                                 C9 CC A0 E8 79 12 C4 B4 70 F5 84 98
>                                 83 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4
>                                 57 E6 6A F4 DC 01 1E AC 0A CC 49 AF
>                                 9C C7 CD C1 14 6E 12 87 F8 22 EB DF 48
>                                 DA 9F F2 8B C1 D2 44 94 E4 3E D0 85
>                                 56 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB
>                                 B0 17 C0 5B 09 86 07 FA 69 DA 65 B8
>                                 D9 8F E6 A1 83 AB 07 98 3C 79 F4 59 08
>                                 8F 83 77 BD A1 A1 76 28 9C 0F CC DC
>                                 CE 1F 16 02 47 98 37 96 87 B1 70 3A EA
>                                 A4 65 77 98 12 27 23 47 A8 1B 79 C0
>                                 EC 53 32 E6 C1 61 7B A0 98 9F FC 8D E8
>                                 5C AF C6 BF 1F D1 40 DC 28 81 34 68
>                                 B7 DA 10 F2 63 52 CB E7 18 85 D5 99 33
>                                 EE 9A 28 FA DF 6D CB C2 CE 9D ED 9D
>                                 BD FD D7 0A E4 89 D3 10 9B DB 6F D9 37
>                                 8B 79 9C 94 C2 44 31 9F 24 EF 21 1D
>                                 5F D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82
>                                 B8 C5 FB 1D E8 FC 67 4F 4D B5 CF A9
>                                 52 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C
>                                 64 89 51 80 7B 1F 02 77 81 FA E9 26
>                                 4C 5F E2 0D 05 55 EE 71 71 FC 35 33 22
>                                 63 F5 36 45 F6 2F D0 13 B7 58 4F 35
>                                 19 59 0A E5 F8 8A 4C 59 32 BF CA B0 06
>                                 C2 6C A9 48 5B 4C 76 24 AE 9D 5B 7B
>                                 79 38 4E 9E 47 12 8A C6 E0 04 37 72 DD
>                                 AF 3D 0D 68 7E D8 80 7B 07 23 CE 40
>                                 4A ED 83 55 56 FD DB 95 B3 1C 33 F1 43
>                                 A8 0E 5E 67 D6 3A D0 89 5E 72 77 7F
>                                 10 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12
>                                 0C 71 73 A0 58 90 54 A8 1C 31 20 DB
>                                 DE DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D
>                                 8A 00 4B 95 6F 8C 12 41 C6 46 10 5E
>                                 9D 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2
>                                 BA 6C 02 DA 27 29 6E E9 54 41 A4 94
>                                 75 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43
>                                 E7 45 85 E8 13 07 1D 9C 37 A8 F3 CA
>                                 F4 19 77 C4 65 D6 18 3E 60 08 74 49 BA
>                                 C8 86 37 8A 0F 79 91 53 20 23 00 B9
>                                 C5 1B 01 DD 10 34 05 42 A0 64 AB 4D 51
>                                 F4 53 35 18 DE 20 1F AA E2 40 0D 6D
>                                 77 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6
>                                 A8 44 8E AE 9C D7 97 6A 99 EE 40 15
>                                 D5 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE
>                                 F2 76 8B 49 6D 66 83 5F BE 05 8E F2
>                                 27 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F
>                                 70 ED 33 CE 31 9D 9F 95 80 9E 73 11
>                                 6C 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96
>                                 94 46 D1 10 3C 1B 9D 40 DD AB EC 8A
>                                 5B 1A B6 19 57 99 09 E8 EC 82 DC 06 39
>                                 86 25 3B 67 B5 17 C5 6E 6E 1C 6C EA
>                                 BE B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3
>                                 B2 7A 40 70 4B C2 D2 A7 B3 42 19 FF
>                                 0B DF 07 0E 6B 8E EF 63 92 D6 15 57 62
>                                 12 99 96 96 A5 34 5A 2C 7C F6 BC 16
>                                 B2 90 C3 11 5E BA 0E E4 22 84 32 50 DA
>                                 1E 37 06 5B EF 69 B7 6F 10 CB DC 4D
>                                 FD DB A3 EF 54 EA DA 55 BA 32 F4 86 6B
>                                 B1 C8 FC 12 9A FC DA FD 2A C2 7F 70
>                                 CE 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF
>                                 2E E3 5F 93 39 AA 00 C7 38 2E 9C F3
>                                 C4 12 46 CF 06 FE 0F 82 82 74 00 71 F8
>                                 28 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7
>                                 45 A6 CD 6E 88 94 08 3A E5 56 36 77 68
>                                 2E 39 D3 45 EE 89 F0 71 42 2D E2 1B
>                                 F5 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3
>                                 37 72 3A 32 CB 1F FD 9D 4A 0E F7 0B
>                                 2B AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2
>                                 E0 A1 48 8E 00 8D 6D C8 10 FD 43 96
>                                 50 07 07 9A BF 50 62 76 3E E1 F7 70 C1
>                                 B0 79 8E 61 E3 FB 05 5F BB 2D 76 69
>                                 89 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7
>                                 F3 0E 3B D5 ED CF EF 58 FA 39 DF 75
>                                 85 2B 8B AA 08 72 52 A7 98 42 95 7B B7
>                                 E7 10 FE DB 54 34 FB 91 24 1C 07 FB
>                                 9C CE D0 46 CF C4 9D 09 49 24 EC]
>                                 18:24:41.343 [AnonymousIoService-1]
>                                 INFO  o.r.s.net.rtmp.RTMPMinaIoHandler
>                                 -
>                                 [localhost/127.0.0.1:8088] SENT:
>                                 DirectBuffer[pos=0 lim=1537 cap=2048:
>                                 03 01
>                                 86 4F 7F 00 00 00 00 6B 04 67 52 A2 70
>                                 5B 51 A2 89 CA CC 8E 70 F0 06 70 0E
>                                 D7 B3 73 7F 07 C1 72 D6 CB 4C C0 45 0F
>                                 F5 4F EC D0 2F 46 2B 76 10 92 1B 0E
>                                 B6 ED 71 73 45 C1 C6 26 0C 69 59 7B BB
>                                 53 B9 10 4D EA C1 E7 7B 70 DE DC F8
>                                 84 90 BF 80 E8 85 B2 46 2C 78 A1 85 01
>                                 8F 8B 05 3F A1 0C 1A 78 70 8C 8E 77
>                                 67 BC 19 2F AB 26 A1 7E 88 D8 CE 24 63
>                                 21 75 3A 5A 6F C2 A1 2D 4F 64 B7 7B
>                                 F7 EF DA 45 B2 51 FD CB 74 49 FD 63 8B
>                                 88 FB DE 5A 3B AB 7F 75 25 BB 35 51
>                                 03 81 12 FF 66 02 3D 88 DC 66 A2 FB 09
>                                 24 9D 86 FD C4 00 C2 8B 6F B7 B2 15
>                                 10 C0 1B 71 A8 3E 88 EB 7E F3 B2 E3 E8
>                                 3C 00 9B 26 BA B4 5F 2C 36 F3 4A 59
>                                 09 1B E5 00 9D E4 66 4D 05 66 D0 D1 D6
>                                 94 4F 64 A1 2E 8D 2F B0 06 01 B3 00
>                                 3D 77 CD 1B DD CC BF E9 CD 1A 6B 68 DD
>                                 1C 7B FD 2E B1 8B 45 FD 5B 48 52 03
>                                 01 E8 F1 0F E7 27 FC 2A 52 7C 14 22 8B
>                                 74 BD D9 97 63 EF FA A3 D9 21 12 0B
>                                 04 62 02 98 41 F2 B4 C3 E3 E2 2B 2A FF
>                                 CA B4 48 1E 82 50 90 94 37 24 7E A1
>                                 03 1A F0 9F 2B BE 64 E5 53 B9 B6 43 8E
>                                 26 6C 63 72 8D B7 7C B8 21 8F BB 1C
>                                 2A 4E C7 EC A7 A9 BC 15 10 E9 4C 46 A5
>                                 60 A9 71 41 DD 25 F5 C1 F6 BD 75 1F
>                                 B0 15 E0 ED C2 4B AC F1 C8 EF A3 44 BE
>                                 90 AB 77 28 BF C0 E0 63 AF D9 07 9D
>                                 93 16 90 7A E2 B4 E8 E2 3E 4B 18 5F 3E
>                                 87 09 BE 36 D0 8F 7C 22 13 9F C5 78
>                                 E0 54 4C A7 77 3F DF 87 4A 28 7B 47 80
>                                 6A F0 50 CC DE 4C 44 41 74 3D 03 37
>                                 8B BF 79 5B 8C B0 2F 6E 9C 98 29 22 49
>                                 2F C9 6D F1 08 C4 4F B1 91 B3 EE 57
>                                 C1 17 5D D0 E8 19 FB 9B D6 A8 56 92 04
>                                 4C 0E E0 52 93 9A EC ED F3 F7 EF D7
>                                 33 E3 CD C7 4B AC B7 A9 A5 13 09 6C 94
>                                 49 72 03 F3 CF 15 31 BC B5 68 C2 49
>                                 E1 6E 7D CB 4E EC FC A7 B7 ED 1C 02 49
>                                 0E 7F 25 EB D1 81 81 C0 A7 49 32 16
>                                 11 31 59 12 43 D3 A6 95 4A C5 FE DF 14
>                                 DA A6 5A C0 D5 6A AF B3 DE 32 2A 13
>                                 03 D3 10 71 0B C0 1E CF DB AA CC A6 B5
>                                 65 2E C4 0B 5C A7 1C 8B 2D 7F C0 4C
>                                 4A A4 0B A0 60 C4 CF B1 BE E4 E4 50 C9
>                                 CC A0 E8 79 12 C4 B4 70 F5 84 98 83
>                                 E2 A9 8F BA FF 88 A2 21 BA 00 3D C4 57
>                                 E6 6A F4 DC 01 1E AC 0A CC 49 AF 9C
>                                 C7 CD C1 14 6E 12 87 F8 22 EB DF 48 DA
>                                 9F F2 8B C1 D2 44 94 E4 3E D0 85 56
>                                 E4 9A FD B9 B3 35 38 1D 15 4D 28 AB B0
>                                 17 C0 5B 09 86 07 FA 69 DA 65 B8 D9
>                                 8F E6 A1 83 AB 07 98 3C 79 F4 59 08 8F
>                                 83 77 BD A1 A1 76 28 9C 0F CC DC CE
>                                 1F 16 02 47 98 37 96 87 B1 70 3A EA A4
>                                 65 77 98 12 27 23 47 A8 1B 79 C0 EC
>                                 53 32 E6 C1 61 7B A0 98 9F FC 8D E8 5C
>                                 AF C6 BF 1F D1 40 DC 28 81 34 68 B7
>                                 DA 10 F2 63 52 CB E7 18 85 D5 99 33 EE
>                                 9A 28 FA DF 6D CB C2 CE 9D ED 9D BD
>                                 FD D7 0A E4 89 D3 10 9B DB 6F D9 37 8B
>                                 79 9C 94 C2 44 31 9F 24 EF 21 1D 5F
>                                 D6 F9 99 7B EF 59 E6 D6 DD 6A 74 82 B8
>                                 C5 FB 1D E8 FC 67 4F 4D B5 CF A9 52
>                                 94 C5 B7 32 A0 45 0A 35 44 59 1E 1C 64
>                                 89 51 80 7B 1F 02 77 81 FA E9 26 4C
>                                 5F E2 0D 05 55 EE 71 71 FC 35 33 22 63
>                                 F5 36 45 F6 2F D0 13 B7 58 4F 35 19
>                                 59 0A E5 F8 8A 4C 59 32 BF CA B0 06 C2
>                                 6C A9 48 5B 4C 76 24 AE 9D 5B 7B 79
>                                 38 4E 9E 47 12 8A C6 E0 04 37 72 DD AF
>                                 3D 0D 68 7E D8 80 7B 07 23 CE 40 4A
>                                 ED 83 55 56 FD DB 95 B3 1C 33 F1 43 A8
>                                 0E 5E 67 D6 3A D0 89 5E 72 77 7F 10
>                                 3C C4 7C 9A A3 55 C5 D3 5B 3A AE 12 0C
>                                 71 73 A0 58 90 54 A8 1C 31 20 DB DE
>                                 DD 35 B1 09 A2 D0 6E 39 39 A5 0A 3D 8A
>                                 00 4B 95 6F 8C 12 41 C6 46 10 5E 9D
>                                 50 85 0E 6B 81 A7 3B 35 A6 38 F5 C2 BA
>                                 6C 02 DA 27 29 6E E9 54 41 A4 94 75
>                                 E8 55 C0 E3 C2 91 8A 1D FB 2B BA 43 E7
>                                 45 85 E8 13 07 1D 9C 37 A8 F3 CA F4
>                                 19 77 C4 65 D6 18 3E 60 08 74 49 BA C8
>                                 86 37 8A 0F 79 91 53 20 23 00 B9 C5
>                                 1B 01 DD 10 34 05 42 A0 64 AB 4D 51 F4
>                                 53 35 18 DE 20 1F AA E2 40 0D 6D 77
>                                 36 1F EE 3A 93 DB 1D D6 A0 23 CC E6 A8
>                                 44 8E AE 9C D7 97 6A 99 EE 40 15 D5
>                                 5A 6D F6 9C 2C 52 CD FA F4 C8 02 EE F2
>                                 76 8B 49 6D 66 83 5F BE 05 8E F2 27
>                                 73 DB 00 EB 9A B4 BF 47 9A BD F1 4F 70
>                                 ED 33 CE 31 9D 9F 95 80 9E 73 11 6C
>                                 03 7B 6E 62 9C D0 AA F6 5D E0 D8 96 94
>                                 46 D1 10 3C 1B 9D 40 DD AB EC 8A 5B
>                                 1A B6 19 57 99 09 E8 EC 82 DC 06 39 86
>                                 25 3B 67 B5 17 C5 6E 6E 1C 6C EA BE
>                                 B8 DD 68 F8 F3 18 F2 3C 99 DC A9 D3 B2
>                                 7A 40 70 4B C2 D2 A7 B3 42 19 FF 0B
>                                 DF 07 0E 6B 8E EF 63 92 D6 15 57 62 12
>                                 99 96 96 A5 34 5A 2C 7C F6 BC 16 B2
>                                 90 C3 11 5E BA 0E E4 22 84 32 50 DA 1E
>                                 37 06 5B EF 69 B7 6F 10 CB DC 4D FD
>                                 DB A3 EF 54 EA DA 55 BA 32 F4 86 6B B1
>                                 C8 FC 12 9A FC DA FD 2A C2 7F 70 CE
>                                 34 38 E6 6A 7D 33 A0 16 FB FD A7 DF 2E
>                                 E3 5F 93 39 AA 00 C7 38 2E 9C F3 C4
>                                 12 46 CF 06 FE 0F 82 82 74 00 71 F8 28
>                                 2F 9B 3F 9A 42 1B 3E A6 0E 90 A7 45
>                                 A6 CD 6E 88 94 08 3A E5 56 36 77 68 2E
>                                 39 D3 45 EE 89 F0 71 42 2D E2 1B F5
>                                 11 F0 FF 05 0C 78 A1 65 CF 3C 9E E3 37
>                                 72 3A 32 CB 1F FD 9D 4A 0E F7 0B 2B
>                                 AA 57 2C 27 B3 A0 2A 0F 85 16 6C E2 E0
>                                 A1 48 8E 00 8D 6D C8 10 FD 43 96 50
>                                 07 07 9A BF 50 62 76 3E E1 F7 70 C1 B0
>                                 79 8E 61 E3 FB 05 5F BB 2D 76 69 89
>                                 F3 1E 62 F6 27 3D 3E 41 0F F5 0F C7 F3
>                                 0E 3B D5 ED CF EF 58 FA 39 DF 75 85
>                                 2B 8B AA 08 72 52 A7 98 42 95 7B B7 E7
>                                 10 FE DB 54 34 FB 91 24 1C 07 FB 9C
>                                 CE D0 46 CF C4 9D 09 49 24 EC]
>                                 18:24:41.343 [AnonymousIoService-1]
>                                 DEBUG o.r.s.net.rtmp.RTMPMinaIoHandler
>                                 -
>                                 messageSent
>                                 18:24:41.343 [AnonymousIoService-1]
>                                 DEBUG
>                                 o.r.server.net.rtmp.BaseRTMPHandler -
>                                 Message sent
>                                 18:24:41.343 [AnonymousIoService-1]
>                                 DEBUG
>                                 o.a.m.filter.executor.ExecutorFilter -
>                                 Exiting since queue is empty for
>                                 localhost/127.0.0.1:8088
>                                 18:25:41.375
>                                 [SocketConnectorIoProcessor-0.0] DEBUG
>                                 o.a.m.filter.executor.ExecutorFilter -
>                                 Launching thread for
>                                 localhost/127.0.0.1:8088
>                                 18:25:41.375 [AnonymousIoService-2]
>                                 INFO  o.r.s.net.rtmp.RTMPMinaIoHandler
>                                 -
>                                 [localhost/127.0.0.1:8088] CLOSED
>                                 18:25:41.375 [AnonymousIoService-2]
>                                 DEBUG test.MyRTMPClientUploader -
>                                 connection closed
>                                 18:25:41.375 [AnonymousIoService-2]
>                                 DEBUG
>                                 o.r.s.net.rtmp.BaseRTMPClientHandler -
>                                 connectionClosed
>                                 18:25:41.375 [AnonymousIoService-2]
>                                 DEBUG org.red5.server.BaseConnection -
>                                 Close, not connected nothing to do.
>                                 18:25:41.406 [AnonymousIoService-2]
>                                 DEBUG org.red5.server.jmx.JMXAgent -
>                                 leaving unregisterMBean...
>                                
>                                
>                                 Any one help me?
>                                
>                                 Thank you in advance,
>                                
>                                 Parthiv
>                                 --
>                                 View this message in context:
>                                 http://www.nabble.com/RTMP-java-Client-for-video-publishing-tp20939125p23540327.html
>                                 Sent from the Red5 - English mailing
>                                 list archive at Nabble.com.
>                                
>                                
>                                 _______________________________________________
>                                 Red5 mailing list
>                                 Red5@...
>                                 http://osflash.org/mailman/listinfo/red5_osflash.org
>                        
>                        
>                         _______________________________________________
>                         Red5 mailing list
>                         Red5@...
>                         http://osflash.org/mailman/listinfo/red5_osflash.org
>                        
>                
>                
>                
>                
>                 --
>                 Regards,
>                 Parthiv Jani
>                
>                
>                 _______________________________________________
>                 Red5 mailing list
>                 Red5@...
>                 http://osflash.org/mailman/listinfo/red5_osflash.org
>                
>        
>        
>         _______________________________________________
>         Red5 mailing list
>         Red5@...
>         http://osflash.org/mailman/listinfo/red5_osflash.org
>        
>
>
>
> --
> Regards,
> Parthiv Jani
>
> _______________________________________________
> Red5 mailing list
> Red5@...
> http://osflash.org/mailman/listinfo/red5_osflash.org

_______________________________________________
Red5 mailing list
Red5@...
http://osflash.org/mailman/listinfo/red5_osflash.org