io.vertx/vertx-proton/3.8.0 : io/vertx/proton/streams/ProtonStreams.class

ProtonStreams
- <init>(): void
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-proton: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse)
The Apache Software License, Version 2.0
public class io.vertx.proton.streams.ProtonStreams
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.proton.streams.ProtonStreams
  super_class: java.lang.Object
{
  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.proton.streams.ProtonStreams this
         0: .line 27
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // io.vertx.proton.streams.ProtonStreams this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/proton/streams/ProtonStreams;

  public static io.vertx.proton.streams.ProtonPublisher<io.vertx.proton.streams.Delivery> createDeliveryConsumer(io.vertx.proton.ProtonConnection, java.lang.String);
    descriptor: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;)Lio/vertx/proton/streams/ProtonPublisher;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.proton.ProtonConnection connection
        start local 1 // java.lang.String address
         0: .line 44
            aload 0 /* connection */
            aload 1 /* address */
            new io.vertx.proton.streams.ProtonPublisherOptions
            dup
            invokespecial io.vertx.proton.streams.ProtonPublisherOptions.<init>:()V
            invokestatic io.vertx.proton.streams.ProtonStreams.createDeliveryConsumer:(Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonPublisherOptions;)Lio/vertx/proton/streams/ProtonPublisher;
            areturn
        end local 1 // java.lang.String address
        end local 0 // io.vertx.proton.ProtonConnection connection
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0  connection  Lio/vertx/proton/ProtonConnection;
            0    1     1     address  Ljava/lang/String;
    Signature: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;)Lio/vertx/proton/streams/ProtonPublisher<Lio/vertx/proton/streams/Delivery;>;
    MethodParameters:
            Name  Flags
      connection  
      address     

  public static io.vertx.proton.streams.ProtonPublisher<io.vertx.proton.streams.Delivery> createDeliveryConsumer(io.vertx.proton.ProtonConnection, java.lang.String, io.vertx.proton.streams.ProtonPublisherOptions);
    descriptor: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonPublisherOptions;)Lio/vertx/proton/streams/ProtonPublisher;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.vertx.proton.ProtonConnection connection
        start local 1 // java.lang.String address
        start local 2 // io.vertx.proton.streams.ProtonPublisherOptions options
         0: .line 68
            new io.vertx.proton.streams.impl.ProtonPublisherImpl
            dup
            aload 1 /* address */
            aload 0 /* connection */
            checkcast io.vertx.proton.impl.ProtonConnectionImpl
            aload 2 /* options */
            invokespecial io.vertx.proton.streams.impl.ProtonPublisherImpl.<init>:(Ljava/lang/String;Lio/vertx/proton/impl/ProtonConnectionImpl;Lio/vertx/proton/streams/ProtonPublisherOptions;)V
            areturn
        end local 2 // io.vertx.proton.streams.ProtonPublisherOptions options
        end local 1 // java.lang.String address
        end local 0 // io.vertx.proton.ProtonConnection connection
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0  connection  Lio/vertx/proton/ProtonConnection;
            0    1     1     address  Ljava/lang/String;
            0    1     2     options  Lio/vertx/proton/streams/ProtonPublisherOptions;
    Signature: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonPublisherOptions;)Lio/vertx/proton/streams/ProtonPublisher<Lio/vertx/proton/streams/Delivery;>;
    MethodParameters:
            Name  Flags
      connection  
      address     
      options     

  public static io.vertx.proton.streams.ProtonPublisher<org.apache.qpid.proton.message.Message> createConsumer(io.vertx.proton.ProtonConnection, java.lang.String);
    descriptor: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;)Lio/vertx/proton/streams/ProtonPublisher;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.proton.ProtonConnection connection
        start local 1 // java.lang.String address
         0: .line 87
            aload 0 /* connection */
            aload 1 /* address */
            new io.vertx.proton.streams.ProtonPublisherOptions
            dup
            invokespecial io.vertx.proton.streams.ProtonPublisherOptions.<init>:()V
            invokestatic io.vertx.proton.streams.ProtonStreams.createConsumer:(Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonPublisherOptions;)Lio/vertx/proton/streams/ProtonPublisher;
            areturn
        end local 1 // java.lang.String address
        end local 0 // io.vertx.proton.ProtonConnection connection
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0  connection  Lio/vertx/proton/ProtonConnection;
            0    1     1     address  Ljava/lang/String;
    Signature: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;)Lio/vertx/proton/streams/ProtonPublisher<Lorg/apache/qpid/proton/message/Message;>;
    MethodParameters:
            Name  Flags
      connection  
      address     

  public static io.vertx.proton.streams.ProtonPublisher<org.apache.qpid.proton.message.Message> createConsumer(io.vertx.proton.ProtonConnection, java.lang.String, io.vertx.proton.streams.ProtonPublisherOptions);
    descriptor: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonPublisherOptions;)Lio/vertx/proton/streams/ProtonPublisher;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // io.vertx.proton.ProtonConnection connection
        start local 1 // java.lang.String address
        start local 2 // io.vertx.proton.streams.ProtonPublisherOptions options
         0: .line 108
            new io.vertx.proton.streams.impl.ProtonPublisherImpl
            dup
            aload 1 /* address */
            aload 0 /* connection */
            checkcast io.vertx.proton.impl.ProtonConnectionImpl
            aload 2 /* options */
            invokespecial io.vertx.proton.streams.impl.ProtonPublisherImpl.<init>:(Ljava/lang/String;Lio/vertx/proton/impl/ProtonConnectionImpl;Lio/vertx/proton/streams/ProtonPublisherOptions;)V
            astore 3 /* publisher */
        start local 3 // io.vertx.proton.streams.impl.ProtonPublisherImpl publisher
         1: .line 110
            new io.vertx.proton.streams.impl.ProtonPublisherWrapperImpl
            dup
            aload 3 /* publisher */
            invokespecial io.vertx.proton.streams.impl.ProtonPublisherWrapperImpl.<init>:(Lio/vertx/proton/streams/impl/ProtonPublisherImpl;)V
            areturn
        end local 3 // io.vertx.proton.streams.impl.ProtonPublisherImpl publisher
        end local 2 // io.vertx.proton.streams.ProtonPublisherOptions options
        end local 1 // java.lang.String address
        end local 0 // io.vertx.proton.ProtonConnection connection
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0  connection  Lio/vertx/proton/ProtonConnection;
            0    2     1     address  Ljava/lang/String;
            0    2     2     options  Lio/vertx/proton/streams/ProtonPublisherOptions;
            1    2     3   publisher  Lio/vertx/proton/streams/impl/ProtonPublisherImpl;
    Signature: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonPublisherOptions;)Lio/vertx/proton/streams/ProtonPublisher<Lorg/apache/qpid/proton/message/Message;>;
    MethodParameters:
            Name  Flags
      connection  
      address     
      options     

  public static io.vertx.proton.streams.ProtonSubscriber<io.vertx.proton.streams.Tracker> createTrackerProducer(io.vertx.proton.ProtonConnection, java.lang.String);
    descriptor: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;)Lio/vertx/proton/streams/ProtonSubscriber;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.proton.ProtonConnection connection
        start local 1 // java.lang.String address
         0: .line 133
            new io.vertx.proton.streams.impl.ProtonSubscriberImpl
            dup
            aload 1 /* address */
            aload 0 /* connection */
            checkcast io.vertx.proton.impl.ProtonConnectionImpl
            invokespecial io.vertx.proton.streams.impl.ProtonSubscriberImpl.<init>:(Ljava/lang/String;Lio/vertx/proton/impl/ProtonConnectionImpl;)V
            areturn
        end local 1 // java.lang.String address
        end local 0 // io.vertx.proton.ProtonConnection connection
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0  connection  Lio/vertx/proton/ProtonConnection;
            0    1     1     address  Ljava/lang/String;
    Signature: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;)Lio/vertx/proton/streams/ProtonSubscriber<Lio/vertx/proton/streams/Tracker;>;
    MethodParameters:
            Name  Flags
      connection  
      address     

  public static io.vertx.proton.streams.ProtonSubscriber<io.vertx.proton.streams.Tracker> createTrackerProducer(io.vertx.proton.ProtonConnection, java.lang.String, io.vertx.proton.streams.ProtonSubscriberOptions);
    descriptor: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonSubscriberOptions;)Lio/vertx/proton/streams/ProtonSubscriber;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.vertx.proton.ProtonConnection connection
        start local 1 // java.lang.String address
        start local 2 // io.vertx.proton.streams.ProtonSubscriberOptions options
         0: .line 158
            new io.vertx.proton.streams.impl.ProtonSubscriberImpl
            dup
            aload 1 /* address */
            aload 0 /* connection */
            checkcast io.vertx.proton.impl.ProtonConnectionImpl
            aload 2 /* options */
            invokespecial io.vertx.proton.streams.impl.ProtonSubscriberImpl.<init>:(Ljava/lang/String;Lio/vertx/proton/impl/ProtonConnectionImpl;Lio/vertx/proton/streams/ProtonSubscriberOptions;)V
            areturn
        end local 2 // io.vertx.proton.streams.ProtonSubscriberOptions options
        end local 1 // java.lang.String address
        end local 0 // io.vertx.proton.ProtonConnection connection
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0  connection  Lio/vertx/proton/ProtonConnection;
            0    1     1     address  Ljava/lang/String;
            0    1     2     options  Lio/vertx/proton/streams/ProtonSubscriberOptions;
    Signature: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonSubscriberOptions;)Lio/vertx/proton/streams/ProtonSubscriber<Lio/vertx/proton/streams/Tracker;>;
    MethodParameters:
            Name  Flags
      connection  
      address     
      options     

  public static io.vertx.proton.streams.ProtonSubscriber<org.apache.qpid.proton.message.Message> createProducer(io.vertx.proton.ProtonConnection, java.lang.String);
    descriptor: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;)Lio/vertx/proton/streams/ProtonSubscriber;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.proton.ProtonConnection connection
        start local 1 // java.lang.String address
         0: .line 179
            new io.vertx.proton.streams.impl.ProtonSubscriberImpl
            dup
            aload 1 /* address */
            aload 0 /* connection */
            checkcast io.vertx.proton.impl.ProtonConnectionImpl
            invokespecial io.vertx.proton.streams.impl.ProtonSubscriberImpl.<init>:(Ljava/lang/String;Lio/vertx/proton/impl/ProtonConnectionImpl;)V
            astore 2 /* subscriber */
        start local 2 // io.vertx.proton.streams.impl.ProtonSubscriberImpl subscriber
         1: .line 181
            new io.vertx.proton.streams.impl.ProtonSubscriberWrapperImpl
            dup
            aload 2 /* subscriber */
            invokespecial io.vertx.proton.streams.impl.ProtonSubscriberWrapperImpl.<init>:(Lio/vertx/proton/streams/impl/ProtonSubscriberImpl;)V
            areturn
        end local 2 // io.vertx.proton.streams.impl.ProtonSubscriberImpl subscriber
        end local 1 // java.lang.String address
        end local 0 // io.vertx.proton.ProtonConnection connection
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0  connection  Lio/vertx/proton/ProtonConnection;
            0    2     1     address  Ljava/lang/String;
            1    2     2  subscriber  Lio/vertx/proton/streams/impl/ProtonSubscriberImpl;
    Signature: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;)Lio/vertx/proton/streams/ProtonSubscriber<Lorg/apache/qpid/proton/message/Message;>;
    MethodParameters:
            Name  Flags
      connection  
      address     

  public static io.vertx.proton.streams.ProtonSubscriber<org.apache.qpid.proton.message.Message> createProducer(io.vertx.proton.ProtonConnection, java.lang.String, io.vertx.proton.streams.ProtonSubscriberOptions);
    descriptor: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonSubscriberOptions;)Lio/vertx/proton/streams/ProtonSubscriber;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // io.vertx.proton.ProtonConnection connection
        start local 1 // java.lang.String address
        start local 2 // io.vertx.proton.streams.ProtonSubscriberOptions options
         0: .line 204
            new io.vertx.proton.streams.impl.ProtonSubscriberImpl
            dup
            aload 1 /* address */
            aload 0 /* connection */
            checkcast io.vertx.proton.impl.ProtonConnectionImpl
            aload 2 /* options */
            invokespecial io.vertx.proton.streams.impl.ProtonSubscriberImpl.<init>:(Ljava/lang/String;Lio/vertx/proton/impl/ProtonConnectionImpl;Lio/vertx/proton/streams/ProtonSubscriberOptions;)V
            astore 3 /* subscriber */
        start local 3 // io.vertx.proton.streams.impl.ProtonSubscriberImpl subscriber
         1: .line 206
            new io.vertx.proton.streams.impl.ProtonSubscriberWrapperImpl
            dup
            aload 3 /* subscriber */
            invokespecial io.vertx.proton.streams.impl.ProtonSubscriberWrapperImpl.<init>:(Lio/vertx/proton/streams/impl/ProtonSubscriberImpl;)V
            areturn
        end local 3 // io.vertx.proton.streams.impl.ProtonSubscriberImpl subscriber
        end local 2 // io.vertx.proton.streams.ProtonSubscriberOptions options
        end local 1 // java.lang.String address
        end local 0 // io.vertx.proton.ProtonConnection connection
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0  connection  Lio/vertx/proton/ProtonConnection;
            0    2     1     address  Ljava/lang/String;
            0    2     2     options  Lio/vertx/proton/streams/ProtonSubscriberOptions;
            1    2     3  subscriber  Lio/vertx/proton/streams/impl/ProtonSubscriberImpl;
    Signature: (Lio/vertx/proton/ProtonConnection;Ljava/lang/String;Lio/vertx/proton/streams/ProtonSubscriberOptions;)Lio/vertx/proton/streams/ProtonSubscriber<Lorg/apache/qpid/proton/message/Message;>;
    MethodParameters:
            Name  Flags
      connection  
      address     
      options     
}
SourceFile: "ProtonStreams.java"
/

io.vertx/ vertx-proton/ 3.8.0/ io/vertx/proton/streams/ProtonStreams.class
