*
 * Steps to run in your own code
 *
 * 1. In your main method `WireSharkListenerFactory.register()`
 * 2. Create Listener factory `val eventListenerFactory = WireSharkListenerFactory(
logFile = File("/tmp/key.log"), tlsVersions = tlsVersions, launch = launch)`
 * 3. Register with `client.eventListenerFactory(eventListenerFactory)`

     * @throws IOException if connection fails
     */
    RdmaConnection connect(String hostname, int port) throws IOException;

    /**
     * Register memory region for RDMA operations
     *
     * @param buffer memory buffer to register
     * @param access access permissions for the memory region
     * @return registered memory region
     * @throws IOException if memory registration fails
     */

def extractGradleApiInfo = tasks.register("extractGradleApiInfo", gradlebuild.binarycompatibility.ExtractGradleApiInfoTask) {
    currentDistributionJars = currentDistroJars
    baselineDistributionJars = baselineJars
    currentUpgradedProperties = currentUpgradedPropertiesFile
    baselineUpgradedProperties = baselineUpgradedPropertiesFile
}

func (c Config) Upload(reqURL string, filename string, payload []byte) (string, error) {
	if !c.Registered() {
		return "", errors.New("Deployment is not registered with SUBNET. Please register the deployment via 'mc license register ALIAS'")
	}

	var body bytes.Buffer
	writer := multipart.NewWriter(&body)
	part, e := writer.CreateFormFile("file", filename)
	if e != nil {
		return "", e
	}

    /**
     * Default constructor.
     */
    public AbstractScriptEngine() {
        // nothing
    }

    /**
     * Register this script engine.
     */
    public void register() {
        ComponentUtil.getScriptEngineFactory().add(getName(), this);
    }

    /**
     * Get the name of this script engine.
     * @return The name of this script engine.
     */

		commonGrid = globalGrid.Load()
	)

	// Register storage REST router only if its a distributed setup.
	registerStorageRESTHandlers(router, endpointServerPools, commonGrid)

	// Register peer REST router only if its a distributed setup.
	registerPeerRESTHandlers(router, commonGrid)

	// Register bootstrap REST router for distributed setups.
	registerBootstrapRESTHandlers(commonGrid)

	// Register distributed namespace lock routers.

            String msg = "Cannot register null or empty aggregation: name=" + name + " value=" + value;
            throw new InvalidQueryRegisteredException(msg);
        }
    }

    protected void checkEsInvalidAggregationCollection(String name, Collection<?> values) {
        if (values == null || values.isEmpty()) {

import gradlebuild.buildutils.tasks.GenerateSubprojectsInfo
import gradlebuild.buildutils.tasks.CheckSubprojectsInfo

tasks.register<GenerateSubprojectsInfo>(GenerateSubprojectsInfo.TASK_NAME)

      eventsReceived.add(event);
    }
  }

  public void testEventOrderingIsPredictable() {
    EventProcessor processor = new EventProcessor();
    bus.register(processor);

    EventRecorder recorder = new EventRecorder();
    bus.register(recorder);

    bus.post(FIRST);

    assertEquals(
        "EventRecorder expected events in order",
        Lists.<Object>newArrayList(FIRST, SECOND),

  configurations {
    val friendsApi = register("friendsApi") {
      isCanBeResolved = true
      isCanBeConsumed = false
      isTransitive = true
    }
    val friendsImplementation = register("friendsImplementation") {
      isCanBeResolved = true
      isCanBeConsumed = false
      isTransitive = false
    }
    val friendsTestImplementation = register("friendsTestImplementation") {