Mirror of Apache Qpid

Related tags

Machine Learning ruby python java csharp cplusplus perl network-server qpid network-client
Overview

We have moved to using individual Git repositories for the Apache Qpid components and you should look to those for new development. This Subversion repository and its Git mirrors now exists mainly for historic reference and some remaining miscellaneous items.

Comments
  • feat(disposition): support undeliverable-here in modified outcomes

    feat(disposition): support undeliverable-here in modified outcomes

    Previously, specifying undeliverable-here as true in a modified outcome simply resulted in the message being rejected. This patch adds tracking to the outgoing link management in order to not redeliver messages to links that indicate that messages are not deliverable there.

    opened by mbroadst 7
  • feat(disposition): respect messageAnnotation mods in modified state

    feat(disposition): respect messageAnnotation mods in modified state

    The modified outcome supports an optional messageAnnotations parameter, allowing the user to modify these annotations for subsequent redelivery with updated valus. This patch implements this behavior in qpidd

    /cc @grs

    opened by mbroadst 2
  • QPID-6470: FieldValue::getFloatingPointValue() converts endian each time...

    QPID-6470: FieldValue::getFloatingPointValue() converts endian each time...

    When calling getFloatingPointValue multiple times, the octets are endian-converted each time. Actually we need to make a copy first and then call convertIfRequired().

    opened by pavelpokutnev 1
  • QPID-6213: fix queue cleaner connection timeouts

    QPID-6213: fix queue cleaner connection timeouts

    Here's a patch that solves a windows issue and possibly is a general solution the base problem.

    1. On windows the queue cleaner runs before there are any queues. This causes an empty list of queues to get posted by the task which exits without rescheduling itself. Then the pollable queue never fires because nothing ever got added. Finally the original task never gets rescheduled and the process is deadlocked. The solution is to add a null pointer to pollable queue in the event that the pollable queue appears empty. This makes sure that the task on the other side of the pollable queue runs. Note that this null may get added even though a batch is already in flight. That will not break anything.
    2. This patch adds a timeout, currently one second, which when exceeded gets the purge function to reschedule it's pending work and exit. This gives the other i/o tasks a shot at running before the queue cleaning starts again. In my testing I had 2000 queues and in its current form the queue cleaner will clean all 2000 before releasing the thread regardless of the batch size presented to the fire function. With this patch the 2000 queues are processed but in chunks that are called by the pollable queue.
    opened by ChugR 1
  • NO-JIRA: Fixed .NET Native-Managed string convervsion

    NO-JIRA: Fixed .NET Native-Managed string convervsion

    The string conversion was not correct when you wanted to convert from native UTF-8 string to a managed one. A conversion method has ben added to QpidMarshal and it is called from Message and TypeTranslator when necessary.

    opened by gaborsulyok 0
  • Get qpid C++ building on OSX.

    Get qpid C++ building on OSX.

    QPID-2536: Implement posix clock_gettime QPID-4280: clock_gettime not available on Mac OS X QPID-4278: Broken OS X Build

    Add documentation to INSTALL and fix up build scripts Conditionalize posix clock routines for MACH sigfillset is a macro on osx. Open question around absolute time pthread wait()s.

    opened by tibbetts 7
Owner
The Apache Software Foundation
The Apache Software Foundation
GitHub
Mirror of Apache SystemML

Apache SystemDS Overview: SystemDS is a versatile system for the end-to-end data science lifecycle from data integration, cleaning, and feature engine

The Apache Software Foundation 940 Dec 25, 2022
Mirror of Apache SystemML

Apache SystemDS Overview: SystemDS is a versatile system for the end-to-end data science lifecycle from data integration, cleaning, and feature engine

The Apache Software Foundation 940 Dec 25, 2022
Now redundant weka mirror. Visit https://github.com/Waikato/weka-trunk for the real deal

weka (mirror) Computing and Mathematical Sciences at the University of Waikato now has an official github organization including a read-only git mirro

Benjamin Petersen 313 Dec 16, 2022
Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning

Oryx 2 is a realization of the lambda architecture built on Apache Spark and Apache Kafka, but with specialization for real-time large scale machine l

Oryx Project 1.8k Dec 28, 2022
Encog java core Apache 2 Encog java core Encog is an advanced machine learning framework that supports a variety of advanced algorithms, as well as support classes to normalize and process data. Machine learning algorithms such as Support Vector Machines, Artificial Neural Networks, Genetic Programming, Bayesian Networks, Hidden Markov Models, Genetic Programming and Genetic Algorithms are supported. License: Apache 2 , .

Encog Machine Learning Framework Encog is a pure-Java/C# machine learning framework that I created back in 2008 to support genetic programming, NEAT/H

Jeff Heaton 739 Dec 17, 2022
Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning

Oryx 2 is a realization of the lambda architecture built on Apache Spark and Apache Kafka, but with specialization for real-time large scale machine l

Oryx Project 1.7k Mar 12, 2021
Apache Spark - A unified analytics engine for large-scale data processing

Apache Spark Spark is a unified analytics engine for large-scale data processing. It provides high-level APIs in Scala, Java, Python, and R, and an op

The Apache Software Foundation 34.7k Jan 2, 2023
Apache Flink

Apache Flink Apache Flink is an open source stream processing framework with powerful stream- and batch-processing capabilities. Learn more about Flin

The Apache Software Foundation 20.4k Jan 5, 2023
Model import deployment framework for retraining models (pytorch, tensorflow,keras) deploying in JVM Micro service environments, mobile devices, iot, and Apache Spark

The Eclipse Deeplearning4J (DL4J) ecosystem is a set of projects intended to support all the needs of a JVM based deep learning application. This mean

Eclipse Foundation 12.7k Dec 30, 2022
Firestorm is a Remote Shuffle Service, and provides the capability for Apache Spark applications to store shuffle data on remote servers

What is Firestorm Firestorm is a Remote Shuffle Service, and provides the capability for Apache Spark applications to store shuffle data on remote ser

Tencent 246 Nov 29, 2022
Flink/Spark Connectors for Apache Doris(Incubating)

Apache Doris (incubating) Connectors The repository contains connectors for Apache Doris (incubating) Flink Doris Connector More information about com

The Apache Software Foundation 30 Dec 7, 2022
Word Count in Apache Spark using Java

Word Count in Apache Spark using Java

Arjun Gautam 2 Feb 24, 2022
Mirror of Apache Deltaspike

Apache DeltaSpike Documentation Mailing Lists Contribution Guide JIRA Apache License v2.0 Apache DeltaSpike is a suite of portable CDI Extensions inte

The Apache Software Foundation 141 Jan 1, 2023
Mirror of Apache Mahout

Welcome to Apache Mahout! The goal of the Apache Mahout™ project is to build an environment for quickly creating scalable, performant machine learning

The Apache Software Foundation 2k Jan 4, 2023
Mirror of Apache Kafka

Apache Kafka See our web site for details on the project. You need to have Java installed. We build and test Apache Kafka with Java 8, 11 and 15. We s

The Apache Software Foundation 23.9k Jan 5, 2023
Mirror of Apache RocketMQ

Apache RocketMQ Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level c

The Apache Software Foundation 18.5k Dec 28, 2022
Mirror of Apache ActiveMQ

Welcome to Apache ActiveMQ Apache ActiveMQ is a high performance Apache 2.0 licensed Message Broker and JMS 1.1 implementation. Getting Started To hel

The Apache Software Foundation 2.1k Jan 2, 2023
Mirror of Apache ActiveMQ Artemis

ActiveMQ Artemis This file describes some minimum 'stuff one needs to know' to get started coding in this project. Source For details about the modify

The Apache Software Foundation 824 Dec 26, 2022
Mirror of Apache Storm

Master Branch: Storm is a distributed realtime computation system. Similar to how Hadoop provides a set of general primitives for doing batch processi

The Apache Software Foundation 6.4k Dec 26, 2022
Mirror of Apache SIS

============================================= Welcome to Apache SIS <http://sis.apache.org> ============================================= SIS is a Ja

The Apache Software Foundation 81 Dec 26, 2022