http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/2m-2s-async/broker-a.properties ---------------------------------------------------------------------- diff --git a/conf/2m-2s-async/broker-a.properties b/conf/2m-2s-async/broker-a.properties deleted file mode 100644 index da6fc5f..0000000 --- a/conf/2m-2s-async/broker-a.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-a -brokerId=0 -deleteWhen=04 -fileReservedTime=48 -brokerRole=ASYNC_MASTER -flushDiskType=ASYNC_FLUSH
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/2m-2s-async/broker-b-s.properties ---------------------------------------------------------------------- diff --git a/conf/2m-2s-async/broker-b-s.properties b/conf/2m-2s-async/broker-b-s.properties deleted file mode 100644 index 9fbe088..0000000 --- a/conf/2m-2s-async/broker-b-s.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-b -brokerId=1 -deleteWhen=04 -fileReservedTime=48 -brokerRole=SLAVE -flushDiskType=ASYNC_FLUSH http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/2m-2s-async/broker-b.properties ---------------------------------------------------------------------- diff --git a/conf/2m-2s-async/broker-b.properties b/conf/2m-2s-async/broker-b.properties deleted file mode 100644 index cb09f9d..0000000 --- a/conf/2m-2s-async/broker-b.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-b -brokerId=0 -deleteWhen=04 -fileReservedTime=48 -brokerRole=ASYNC_MASTER -flushDiskType=ASYNC_FLUSH http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/2m-2s-sync/broker-a-s.properties ---------------------------------------------------------------------- diff --git a/conf/2m-2s-sync/broker-a-s.properties b/conf/2m-2s-sync/broker-a-s.properties deleted file mode 100644 index 10d1555..0000000 --- a/conf/2m-2s-sync/broker-a-s.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-a -brokerId=1 -deleteWhen=04 -fileReservedTime=48 -brokerRole=SLAVE -flushDiskType=ASYNC_FLUSH http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/2m-2s-sync/broker-a.properties ---------------------------------------------------------------------- diff --git a/conf/2m-2s-sync/broker-a.properties b/conf/2m-2s-sync/broker-a.properties deleted file mode 100644 index 82c4631..0000000 --- a/conf/2m-2s-sync/broker-a.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-a -brokerId=0 -deleteWhen=04 -fileReservedTime=48 -brokerRole=SYNC_MASTER -flushDiskType=ASYNC_FLUSH http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/2m-2s-sync/broker-b-s.properties ---------------------------------------------------------------------- diff --git a/conf/2m-2s-sync/broker-b-s.properties b/conf/2m-2s-sync/broker-b-s.properties deleted file mode 100644 index 9fbe088..0000000 --- a/conf/2m-2s-sync/broker-b-s.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-b -brokerId=1 -deleteWhen=04 -fileReservedTime=48 -brokerRole=SLAVE -flushDiskType=ASYNC_FLUSH http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/2m-2s-sync/broker-b.properties ---------------------------------------------------------------------- diff --git a/conf/2m-2s-sync/broker-b.properties b/conf/2m-2s-sync/broker-b.properties deleted file mode 100644 index 29a4264..0000000 --- a/conf/2m-2s-sync/broker-b.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-b -brokerId=0 -deleteWhen=04 -fileReservedTime=48 -brokerRole=SYNC_MASTER -flushDiskType=ASYNC_FLUSH http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/2m-noslave/broker-a.properties ---------------------------------------------------------------------- diff --git a/conf/2m-noslave/broker-a.properties b/conf/2m-noslave/broker-a.properties deleted file mode 100644 index da6fc5f..0000000 --- a/conf/2m-noslave/broker-a.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-a -brokerId=0 -deleteWhen=04 -fileReservedTime=48 -brokerRole=ASYNC_MASTER -flushDiskType=ASYNC_FLUSH http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/2m-noslave/broker-b.properties ---------------------------------------------------------------------- diff --git a/conf/2m-noslave/broker-b.properties b/conf/2m-noslave/broker-b.properties deleted file mode 100644 index cb09f9d..0000000 --- a/conf/2m-noslave/broker-b.properties +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName=DefaultCluster -brokerName=broker-b -brokerId=0 -deleteWhen=04 -fileReservedTime=48 -brokerRole=ASYNC_MASTER -flushDiskType=ASYNC_FLUSH http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/broker.conf ---------------------------------------------------------------------- diff --git a/conf/broker.conf b/conf/broker.conf deleted file mode 100644 index 0c0b28b..0000000 --- a/conf/broker.conf +++ /dev/null @@ -1,22 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - -brokerClusterName = DefaultCluster -brokerName = broker-a -brokerId = 0 -deleteWhen = 04 -fileReservedTime = 48 -brokerRole = ASYNC_MASTER -flushDiskType = ASYNC_FLUSH http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/logback_broker.xml ---------------------------------------------------------------------- diff --git a/conf/logback_broker.xml b/conf/logback_broker.xml deleted file mode 100644 index 05c0ee4..0000000 --- a/conf/logback_broker.xml +++ /dev/null @@ -1,328 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - --> - -<configuration> - <appender name="DefaultAppender" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/broker_default.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/broker_default.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>10</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - - <appender name="RocketmqBrokerAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/broker.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/broker.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>20</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>128MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqBrokerAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqBrokerAppender_inner"/> - </appender> - - <appender name="RocketmqProtectionAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/protection.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/protection.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>10</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqProtectionAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqProtectionAppender_inner"/> - </appender> - - <appender name="RocketmqWaterMarkAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/watermark.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/watermark.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>10</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqWaterMarkAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqWaterMarkAppender_inner"/> - </appender> - - <appender name="RocketmqStoreAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/store.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/store.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>10</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>128MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqStoreAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqStoreAppender_inner"/> - </appender> - - <appender name="RocketmqRemotingAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/remoting.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/remoting.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>10</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqRemotingAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqRemotingAppender_inner"/> - </appender> - - <appender name="RocketmqStoreErrorAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/storeerror.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/storeerror.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>10</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqStoreErrorAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqStoreErrorAppender_inner"/> - </appender> - - - <appender name="RocketmqTransactionAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/transaction.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/transaction.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>10</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqTransactionAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqTransactionAppender_inner"/> - </appender> - - <appender name="RocketmqRebalanceLockAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/lock.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/lock.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>5</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqRebalanceLockAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqRebalanceLockAppender_inner"/> - </appender> - - <appender name="RocketmqStatsAppender" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/stats.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/stats.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>5</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - - <appender name="RocketmqCommercialAppender" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/commercial.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/commercial.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>10</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>500MB</maxFileSize> - </triggeringPolicy> - </appender> - - <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> - <append>true</append> - <encoder> - <pattern>%d{yyy-MM-dd HH\:mm\:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - - <logger name="RocketmqBroker" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqBrokerAppender"/> - </logger> - - <logger name="RocketmqProtection" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqProtectionAppender"/> - </logger> - - <logger name="RocketmqWaterMark" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqWaterMarkAppender"/> - </logger> - - <logger name="RocketmqCommon" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqBrokerAppender"/> - </logger> - - <logger name="RocketmqStore" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqStoreAppender"/> - </logger> - - <logger name="RocketmqStoreError" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqStoreErrorAppender"/> - </logger> - - <logger name="RocketmqTransaction" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqTransactionAppender"/> - </logger> - - <logger name="RocketmqRebalanceLock" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqRebalanceLockAppender"/> - </logger> - - <logger name="RocketmqRemoting" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqRemotingAppender"/> - </logger> - - <logger name="RocketmqStats" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqStatsAppender"/> - </logger> - - <logger name="RocketmqCommercial" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqCommercialAppender"/> - </logger> - - <root> - <level value="INFO"/> - <appender-ref ref="DefaultAppender"/> - </root> -</configuration> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/logback_filtersrv.xml ---------------------------------------------------------------------- diff --git a/conf/logback_filtersrv.xml b/conf/logback_filtersrv.xml deleted file mode 100644 index 1e6ba43..0000000 --- a/conf/logback_filtersrv.xml +++ /dev/null @@ -1,91 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - --> - -<configuration> - <appender name="DefaultAppender" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/filtersrv_default.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/filtersrv_default.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>5</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - - <appender name="RocketmqFiltersrvAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/filtersrv.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/filtersrv.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>5</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqFiltersrvAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqFiltersrvAppender_inner"/> - <discardingThreshold>0</discardingThreshold> - </appender> - - <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> - <append>true</append> - <encoder> - <pattern>%d{yyy-MM-dd HH\:mm\:ss,SSS} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - - <logger name="RocketmqFiltersrv" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqFiltersrvAppender"/> - </logger> - - <logger name="RocketmqCommon" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqFiltersrvAppender"/> - </logger> - - <logger name="RocketmqRemoting" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqFiltersrvAppender"/> - </logger> - - <root> - <level value="INFO"/> - <appender-ref ref="DefaultAppender"/> - </root> -</configuration> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/logback_namesrv.xml ---------------------------------------------------------------------- diff --git a/conf/logback_namesrv.xml b/conf/logback_namesrv.xml deleted file mode 100644 index 648e7f5..0000000 --- a/conf/logback_namesrv.xml +++ /dev/null @@ -1,91 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - --> - -<configuration> - <appender name="DefaultAppender" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/namesrv_default.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/namesrv_default.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>5</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - - <appender name="RocketmqNamesrvAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/namesrv.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/namesrv.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>5</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqNamesrvAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqNamesrvAppender_inner"/> - <discardingThreshold>0</discardingThreshold> - </appender> - - <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> - <append>true</append> - <encoder> - <pattern>%d{yyy-MM-dd HH\:mm\:ss,SSS} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - - <logger name="RocketmqNamesrv" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqNamesrvAppender"/> - </logger> - - <logger name="RocketmqCommon" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqNamesrvAppender"/> - </logger> - - <logger name="RocketmqRemoting" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqNamesrvAppender"/> - </logger> - - <root> - <level value="INFO"/> - <appender-ref ref="DefaultAppender"/> - </root> -</configuration> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/conf/logback_tools.xml ---------------------------------------------------------------------- diff --git a/conf/logback_tools.xml b/conf/logback_tools.xml deleted file mode 100644 index 1dd4e50..0000000 --- a/conf/logback_tools.xml +++ /dev/null @@ -1,96 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - --> - -<configuration> - <appender name="DefaultAppender" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/tools_default.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/tools_default.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>5</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - - <appender name="RocketmqToolsAppender_inner" - class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>${user.home}/logs/rocketmqlogs/tools.log</file> - <append>true</append> - <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy"> - <fileNamePattern>${user.home}/logs/rocketmqlogs/otherdays/tools.%i.log - </fileNamePattern> - <minIndex>1</minIndex> - <maxIndex>5</maxIndex> - </rollingPolicy> - <triggeringPolicy - class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> - <maxFileSize>100MB</maxFileSize> - </triggeringPolicy> - <encoder> - <pattern>%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - <appender name="RocketmqToolsAppender" class="ch.qos.logback.classic.AsyncAppender"> - <appender-ref ref="RocketmqToolsAppender_inner"/> - </appender> - - - <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> - <append>true</append> - <encoder> - <pattern>%d{yyy-MM-dd HH\:mm\:ss,GMT+8} %p %t - %m%n</pattern> - <charset class="java.nio.charset.Charset">UTF-8</charset> - </encoder> - </appender> - - <logger name="RocketmqTools" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqToolsAppender"/> - </logger> - - <logger name="RocketmqCommon" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqBrokerAppender"/> - </logger> - - <logger name="RocketmqStore" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqBrokerAppender"/> - </logger> - - <logger name="RocketmqRemoting" additivity="false"> - <level value="INFO"/> - <appender-ref ref="RocketmqBrokerAppender"/> - </logger> - - <root> - <level value="INFO"/> - <appender-ref ref="DefaultAppender"/> - </root> -</configuration> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/LICENSE-BIN ---------------------------------------------------------------------- diff --git a/distribution/LICENSE-BIN b/distribution/LICENSE-BIN new file mode 100644 index 0000000..9796b3c --- /dev/null +++ b/distribution/LICENSE-BIN @@ -0,0 +1,299 @@ + Apache License + Version 2.0, January 2004 + http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + "License" shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + "Licensor" shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + "Legal Entity" shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + "control" means (properties) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + "You" (or "Your") shall mean an individual or Legal Entity + exercising permissions granted by this License. + + "Source" form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + "Object" form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + "Work" shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + "Derivative Works" shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + "Contribution" shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, "submitted" + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as "Not a Contribution." + + "Contributor" shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, + publicly display, publicly perform, sublicense, and distribute the + Work and such Derivative Works in Source or Object form. + + 3. Grant of Patent License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + (except as stated in this section) patent license to make, have made, + use, offer to sell, sell, import, and otherwise transfer the Work, + where such license applies only to those patent claims licensable + by such Contributor that are necessarily infringed by their + Contribution(s) alone or by combination of their Contribution(s) + with the Work to which such Contribution(s) was submitted. If You + institute patent litigation against any entity (including a + cross-claim or counterclaim in a lawsuit) alleging that the Work + or a Contribution incorporated within the Work constitutes direct + or contributory patent infringement, then any patent licenses + granted to You under this License for that Work shall terminate + as of the date such litigation is filed. + + 4. Redistribution. You may reproduce and distribute copies of the + Work or Derivative Works thereof in any medium, with or without + modifications, and in Source or Object form, provided that You + meet the following conditions: + + (a) You must give any other recipients of the Work or + Derivative Works a copy of this License; and + + (b) You must cause any modified files to carry prominent notices + stating that You changed the files; and + + (c) You must retain, in the Source form of any Derivative Works + that You distribute, all copyright, patent, trademark, and + attribution notices from the Source form of the Work, + excluding those notices that do not pertain to any part of + the Derivative Works; and + + (d) If the Work includes a "NOTICE" text file as part of its + distribution, then any Derivative Works that You distribute must + include a readable copy of the attribution notices contained + within such NOTICE file, excluding those notices that do not + pertain to any part of the Derivative Works, in at least one + of the following places: within a NOTICE text file distributed + as part of the Derivative Works; within the Source form or + documentation, if provided along with the Derivative Works; or, + within a display generated by the Derivative Works, if and + wherever such third-party notices normally appear. The contents + of the NOTICE file are for informational purposes only and + do not modify the License. You may add Your own attribution + notices within Derivative Works that You distribute, alongside + or as an addendum to the NOTICE text from the Work, provided + that such additional attribution notices cannot be construed + as modifying the License. + + You may add Your own copyright statement to Your modifications and + may provide additional or different license terms and conditions + for use, reproduction, or distribution of Your modifications, or + for any such Derivative Works as a whole, provided Your use, + reproduction, and distribution of the Work otherwise complies with + the conditions stated in this License. + + 5. Submission of Contributions. Unless You explicitly state otherwise, + any Contribution intentionally submitted for inclusion in the Work + by You to the Licensor shall be under the terms and conditions of + this License, without any additional terms or conditions. + Notwithstanding the above, nothing herein shall supersede or modify + the terms of any separate license agreement you may have executed + with Licensor regarding such Contributions. + + 6. Trademarks. This License does not grant permission to use the trade + names, trademarks, service marks, or product names of the Licensor, + except as required for reasonable and customary use in describing the + origin of the Work and reproducing the content of the NOTICE file. + + 7. Disclaimer of Warranty. Unless required by applicable law or + agreed to in writing, Licensor provides the Work (and each + Contributor provides its Contributions) on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + implied, including, without limitation, any warranties or conditions + of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A + PARTICULAR PURPOSE. You are solely responsible for determining the + appropriateness of using or redistributing the Work and assume any + risks associated with Your exercise of permissions under this License. + + 8. Limitation of Liability. In no event and under no legal theory, + whether in tort (including negligence), contract, or otherwise, + unless required by applicable law (such as deliberate and grossly + negligent acts) or agreed to in writing, shall any Contributor be + liable to You for damages, including any direct, indirect, special, + incidental, or consequential damages of any character arising as a + result of this License or out of the use or inability to use the + Work (including but not limited to damages for loss of goodwill, + work stoppage, computer failure or malfunction, or any and all + other commercial damages or losses), even if such Contributor + has been advised of the possibility of such damages. + + 9. Accepting Warranty or Additional Liability. While redistributing + the Work or Derivative Works thereof, You may choose to offer, + and charge a fee for, acceptance of support, warranty, indemnity, + or other liability obligations and/or rights consistent with this + License. However, in accepting such obligations, You may act only + on Your own behalf and on Your sole responsibility, not on behalf + of any other Contributor, and only if You agree to indemnify, + defend, and hold each Contributor harmless for any liability + incurred by, or claims asserted against, such Contributor by reason + of your accepting any such warranty or additional liability. + + END OF TERMS AND CONDITIONS + + APPENDIX: How to apply the Apache License to your work. + + To apply the Apache License to your work, attach the following + boilerplate notice, with the fields enclosed by brackets "[]" + replaced with your own identifying information. (Don't include + the brackets!) The text should be enclosed in the appropriate + comment syntax for the file format. We also recommend that a + file or class name and description of purpose be included on the + same "printed page" as the copyright notice for easier + identification within third-party archives. + + Copyright [yyyy] [name of copyright owner] + + Licensed under the Apache License, Version 2.0 (the "License"); + you may not use this file except in compliance with the License. + You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +------ +This product has a bundle logback, which is available under the EPL v1.0 License. +The source code of logback can be found at https://github.com/qos-ch/logback. + +Logback LICENSE +--------------- + +Logback: the reliable, generic, fast and flexible logging framework. +Copyright (C) 1999-2015, QOS.ch. All rights reserved. + +This program and the accompanying materials are dual-licensed under +either the terms of the Eclipse Public License v1.0 as published by +the Eclipse Foundation + + or (per the licensee's choosing) + +under the terms of the GNU Lesser General Public License version 2.1 +as published by the Free Software Foundation. + +------ +This product has a bundle slf4j, which is available under the MIT License. +The source code of slf4j can be found at https://github.com/qos-ch/slf4j. + + Copyright (c) 2004-2017 QOS.ch + All rights reserved. + + Permission is hereby granted, free of charge, to any person obtaining + a copy of this software and associated documentation files (the + "Software"), to deal in the Software without restriction, including + without limitation the rights to use, copy, modify, merge, publish, + distribute, sublicense, and/or sell copies of the Software, and to + permit persons to whom the Software is furnished to do so, subject to + the following conditions: + + The above copyright notice and this permission notice shall be + included in all copies or substantial portions of the Software. + + THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, + EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF + MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND + NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE + LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION + OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION + WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. + +------ +This product has a bundle fastjson, which is available under the ASL2 License. +The source code of fastjson can be found at https://github.com/alibaba/fastjson. + + Copyright 1999-2016 Alibaba Group Holding Ltd. + + Licensed under the Apache License, Version 2.0 (the "License"); + you may not use this file except in compliance with the License. + You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +------ +This product has a bundle javassist, which is available under the ASL2 License. +The source code of javassist can be found at https://github.com/jboss-javassist/javassist. + + Copyright (C) 1999- by Shigeru Chiba, All rights reserved. + + Javassist (JAVA programming ASSISTant) makes Java bytecode manipulation simple. + It is a class library for editing bytecodes in Java; it enables Java programs to define a new class + at runtime and to modify a class file when the JVM loads it. Unlike other similar bytecode editors, + Javassist provides two levels of API: source level and bytecode level. If the users use the source- level API, + they can edit a class file without knowledge of the specifications of the Java bytecode. + The whole API is designed with only the vocabulary of the Java language. + You can even specify inserted bytecode in the form of source text; Javassist compiles it on the fly. + On the other hand, the bytecode-level API allows the users to directly edit a class file as other editors. + + This software is distributed under the Mozilla Public License Version 1.1, + the GNU Lesser General Public License Version 2.1 or later, or the Apache License Version 2.0. + +------ +This product has a bundle jna, which is available under the ASL2 License. +The source code of jna can be found at https://github.com/java-native-access/jna. + + This copy of JNA is licensed under the + Apache (Software) License, version 2.0 ("the License"). + See the License for details about distribution rights, and the + specific rights regarding derivate works. + + You may obtain a copy of the License at: + + http://www.apache.org/licenses/ + + A copy is also included in the downloadable source code package + containing JNA, in file "AL2.0", under the same directory + as this file. \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/NOTICE-BIN ---------------------------------------------------------------------- diff --git a/distribution/NOTICE-BIN b/distribution/NOTICE-BIN new file mode 100644 index 0000000..73589d4 --- /dev/null +++ b/distribution/NOTICE-BIN @@ -0,0 +1,36 @@ +Apache RocketMQ (incubating) +Copyright 2016-2017 The Apache Software Foundation + +This product includes software developed at +The Apache Software Foundation (http://www.apache.org/). + +------ +This product has a bundle netty: + The Netty Project + ================= + +Please visit the Netty web site for more information: + + * http://netty.io/ + +Copyright 2014 The Netty Project + +The Netty Project licenses this file to you under the Apache License, +version 2.0 (the "License"); you may not use this file except in compliance +with the License. You may obtain a copy of the License at: + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, WITHOUT +WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the +License for the specific language governing permissions and limitations +under the License. + +Also, please refer to each LICENSE.<component>.txt file, which is located in +the 'license' directory of the distribution file, for the license terms of the +components that this product depends on. + +------ +This product has a bundle commons-lang, which includes software from the Spring Framework, +under the Apache License 2.0 (see: StringUtils.containsWhitespace()) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/README.md ---------------------------------------------------------------------- diff --git a/distribution/bin/README.md b/distribution/bin/README.md new file mode 100644 index 0000000..efbb67d --- /dev/null +++ b/distribution/bin/README.md @@ -0,0 +1,29 @@ +### Operating system tuning +Before deploying broker servers, it's highly recommended to run **os.sh**, which is to optimize your operating system for better performance. + +## Notice +### os.sh should be executed only once with root permission. +### os.sh parameter settings are for reference purpose only. You can tune them according to your target host configurations. + + +### Start broker +* Unix platform + + `nohup sh mqbroker &` + +### Shutdown broker + sh mqshutdown broker + +### Start Nameserver +* Unix platform + + `nohup sh mqnamesrv &` + +### Shutdown Nameserver + sh mqshutdown namesrv + +### Update or create Topic + sh mqadmin updateTopic -b 127.0.0.1:10911 -t TopicA + +### Update or create subscription group + sh mqadmin updateSubGroup -b 127.0.0.1:10911 -g SubGroupA \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/cachedog.sh ---------------------------------------------------------------------- diff --git a/distribution/bin/cachedog.sh b/distribution/bin/cachedog.sh new file mode 100644 index 0000000..9329fdb --- /dev/null +++ b/distribution/bin/cachedog.sh @@ -0,0 +1,42 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +export PATH=$PATH:/sbin + +while true; do + nr_free_pages=`fgrep -A 10 Normal /proc/zoneinfo |grep nr_free_pages |awk -F ' ' '{print $2}'` + high=`fgrep -A 10 Normal /proc/zoneinfo |grep high |awk -F ' ' '{print $2}'` + + NOW_DATE=`date +%D` + NOW_TIME=`date +%T` + + if [ ${nr_free_pages} -le ${high} ]; then + sysctl -w vm.drop_caches=3 + nr_free_pages_new=`fgrep -A 10 Normal /proc/zoneinfo |grep nr_free_pages |awk -F ' ' '{print $2}'` + + printf "%s %s [CLEAN] nr_free_pages < high, clean cache. nr_free_pages=%s ====> nr_free_pages=%s\n" "${NOW_DATE}" "${NOW_TIME}" ${nr_free_pages} ${nr_free_pages_new} + + sysctl -w vm.drop_caches=1 + echo + echo + echo + else + printf "%s %s [NOTHING] nr_free_pages=%s high=%s\n" "${NOW_DATE}" "${NOW_TIME}" ${nr_free_pages} ${high} + fi + + sleep 1 +done http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/cleancache.sh ---------------------------------------------------------------------- diff --git a/distribution/bin/cleancache.sh b/distribution/bin/cleancache.sh new file mode 100644 index 0000000..9c6e9ab --- /dev/null +++ b/distribution/bin/cleancache.sh @@ -0,0 +1,20 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +export PATH=$PATH:/sbin + +sysctl -w vm.drop_caches=3 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/cleancache.v1.sh ---------------------------------------------------------------------- diff --git a/distribution/bin/cleancache.v1.sh b/distribution/bin/cleancache.v1.sh new file mode 100644 index 0000000..b334841 --- /dev/null +++ b/distribution/bin/cleancache.v1.sh @@ -0,0 +1,40 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +export PATH=$PATH:/sbin + +# +# GB +# +function changeFreeCache() +{ + EXTRA=$1 + MIN=$2 + sysctl -w vm.extra_free_kbytes=${EXTRA}000000 + sysctl -w vm.min_free_kbytes=${MIN}000000 +} + + +if [ $# -ne 1 ] +then + echo "Usage: $0 freecache(GB)" + echo "Example: $0 15" + exit +fi + +changeFreeCache 3 $1 +changeFreeCache 3 1 http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqadmin ---------------------------------------------------------------------- diff --git a/distribution/bin/mqadmin b/distribution/bin/mqadmin new file mode 100644 index 0000000..cd0253b --- /dev/null +++ b/distribution/bin/mqadmin @@ -0,0 +1,45 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +if [ -z "$ROCKETMQ_HOME" ] ; then + ## resolve links - $0 may be a link to maven's home + PRG="$0" + + # need this for relative symlinks + while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG="`dirname "$PRG"`/$link" + fi + done + + saveddir=`pwd` + + ROCKETMQ_HOME=`dirname "$PRG"`/.. + + # make it fully qualified + ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` + + cd "$saveddir" +fi + +export ROCKETMQ_HOME + +sh ${ROCKETMQ_HOME}/bin/tools.sh org.apache.rocketmq.tools.command.MQAdminStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqadmin.cmd ---------------------------------------------------------------------- diff --git a/distribution/bin/mqadmin.cmd b/distribution/bin/mqadmin.cmd new file mode 100644 index 0000000..4e061f0 --- /dev/null +++ b/distribution/bin/mqadmin.cmd @@ -0,0 +1,18 @@ +@echo off +rem Licensed to the Apache Software Foundation (ASF) under one or more +rem contributor license agreements. See the NOTICE file distributed with +rem this work for additional information regarding copyright ownership. +rem The ASF licenses this file to You under the Apache License, Version 2.0 +rem (the "License"); you may not use this file except in compliance with +rem the License. You may obtain a copy of the License at +rem +rem http://www.apache.org/licenses/LICENSE-2.0 +rem +rem Unless required by applicable law or agreed to in writing, software +rem distributed under the License is distributed on an "AS IS" BASIS, +rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +rem See the License for the specific language governing permissions and +rem limitations under the License. + +if not exist "%ROCKETMQ_HOME%\bin\tools.cmd" echo Please set the ROCKETMQ_HOME variable in your environment! & EXIT /B 1 +call "%ROCKETMQ_HOME%\bin\tools.cmd" org.apache.rocketmq.tools.command.MQAdminStartup %* \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqadmin.xml ---------------------------------------------------------------------- diff --git a/distribution/bin/mqadmin.xml b/distribution/bin/mqadmin.xml new file mode 100644 index 0000000..d014743 --- /dev/null +++ b/distribution/bin/mqadmin.xml @@ -0,0 +1,43 @@ +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + --> + +<java> + <debug>false</debug> + + <javahome>${JAVA_HOME}</javahome> + + <jvmtype>server</jvmtype> + + <mainclass>org.apache.rocketmq.tools.command.MQAdminStartup</mainclass> + + <properties> + <java.ext.dirs>${cpd}/../lib</java.ext.dirs> + <rocketmq.home.dir>${cpd}/..</rocketmq.home.dir> + </properties> + + <classpaths> + </classpaths> + + <options> + <-Xms512m></-Xms512m> + <-Xmx1g></-Xmx1g> + <-XX:NewSize>256M</-XX:NewSize> + <-XX:MaxNewSize>512M</-XX:MaxNewSize> + <-XX:PermSize>128M</-XX:PermSize> + <-XX:MaxPermSize>128M</-XX:MaxPermSize> + </options> +</java> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqbroker ---------------------------------------------------------------------- diff --git a/distribution/bin/mqbroker b/distribution/bin/mqbroker new file mode 100644 index 0000000..6a79c39 --- /dev/null +++ b/distribution/bin/mqbroker @@ -0,0 +1,45 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +if [ -z "$ROCKETMQ_HOME" ] ; then + ## resolve links - $0 may be a link to maven's home + PRG="$0" + + # need this for relative symlinks + while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG="`dirname "$PRG"`/$link" + fi + done + + saveddir=`pwd` + + ROCKETMQ_HOME=`dirname "$PRG"`/.. + + # make it fully qualified + ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` + + cd "$saveddir" +fi + +export ROCKETMQ_HOME + +sh ${ROCKETMQ_HOME}/bin/runbroker.sh org.apache.rocketmq.broker.BrokerStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqbroker.cmd ---------------------------------------------------------------------- diff --git a/distribution/bin/mqbroker.cmd b/distribution/bin/mqbroker.cmd new file mode 100644 index 0000000..3efb475 --- /dev/null +++ b/distribution/bin/mqbroker.cmd @@ -0,0 +1,23 @@ +@echo off +rem Licensed to the Apache Software Foundation (ASF) under one or more +rem contributor license agreements. See the NOTICE file distributed with +rem this work for additional information regarding copyright ownership. +rem The ASF licenses this file to You under the Apache License, Version 2.0 +rem (the "License"); you may not use this file except in compliance with +rem the License. You may obtain a copy of the License at +rem +rem http://www.apache.org/licenses/LICENSE-2.0 +rem +rem Unless required by applicable law or agreed to in writing, software +rem distributed under the License is distributed on an "AS IS" BASIS, +rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +rem See the License for the specific language governing permissions and +rem limitations under the License. + +if not exist "%ROCKETMQ_HOME%\bin\runbroker.cmd" echo Please set the ROCKETMQ_HOME variable in your environment! & EXIT /B 1 + +call "%ROCKETMQ_HOME%\bin\runbroker.cmd" org.apache.rocketmq.broker.BrokerStartup %* + +IF %ERRORLEVEL% EQU 0 ( + ECHO "Broker starts OK" +) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqbroker.numanode0 ---------------------------------------------------------------------- diff --git a/distribution/bin/mqbroker.numanode0 b/distribution/bin/mqbroker.numanode0 new file mode 100644 index 0000000..b7486a7 --- /dev/null +++ b/distribution/bin/mqbroker.numanode0 @@ -0,0 +1,47 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +if [ -z "$ROCKETMQ_HOME" ] ; then + ## resolve links - $0 may be a link to maven's home + PRG="$0" + + # need this for relative symlinks + while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG="`dirname "$PRG"`/$link" + fi + done + + saveddir=`pwd` + + ROCKETMQ_HOME=`dirname "$PRG"`/.. + + # make it fully qualified + ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` + + cd "$saveddir" +fi + +export ROCKETMQ_HOME + +export RMQ_NUMA_NODE=0 + +sh ${ROCKETMQ_HOME}/bin/mqbroker $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqbroker.numanode1 ---------------------------------------------------------------------- diff --git a/distribution/bin/mqbroker.numanode1 b/distribution/bin/mqbroker.numanode1 new file mode 100644 index 0000000..c301fed --- /dev/null +++ b/distribution/bin/mqbroker.numanode1 @@ -0,0 +1,47 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +if [ -z "$ROCKETMQ_HOME" ] ; then + ## resolve links - $0 may be a link to maven's home + PRG="$0" + + # need this for relative symlinks + while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG="`dirname "$PRG"`/$link" + fi + done + + saveddir=`pwd` + + ROCKETMQ_HOME=`dirname "$PRG"`/.. + + # make it fully qualified + ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` + + cd "$saveddir" +fi + +export ROCKETMQ_HOME + +export RMQ_NUMA_NODE=1 + +sh ${ROCKETMQ_HOME}/bin/mqbroker $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqbroker.numanode2 ---------------------------------------------------------------------- diff --git a/distribution/bin/mqbroker.numanode2 b/distribution/bin/mqbroker.numanode2 new file mode 100644 index 0000000..ea95304 --- /dev/null +++ b/distribution/bin/mqbroker.numanode2 @@ -0,0 +1,47 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +if [ -z "$ROCKETMQ_HOME" ] ; then + ## resolve links - $0 may be a link to maven's home + PRG="$0" + + # need this for relative symlinks + while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG="`dirname "$PRG"`/$link" + fi + done + + saveddir=`pwd` + + ROCKETMQ_HOME=`dirname "$PRG"`/.. + + # make it fully qualified + ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` + + cd "$saveddir" +fi + +export ROCKETMQ_HOME + +export RMQ_NUMA_NODE=2 + +sh ${ROCKETMQ_HOME}/bin/mqbroker $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqbroker.numanode3 ---------------------------------------------------------------------- diff --git a/distribution/bin/mqbroker.numanode3 b/distribution/bin/mqbroker.numanode3 new file mode 100644 index 0000000..25d3d1d --- /dev/null +++ b/distribution/bin/mqbroker.numanode3 @@ -0,0 +1,47 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +if [ -z "$ROCKETMQ_HOME" ] ; then + ## resolve links - $0 may be a link to maven's home + PRG="$0" + + # need this for relative symlinks + while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG="`dirname "$PRG"`/$link" + fi + done + + saveddir=`pwd` + + ROCKETMQ_HOME=`dirname "$PRG"`/.. + + # make it fully qualified + ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` + + cd "$saveddir" +fi + +export ROCKETMQ_HOME + +export RMQ_NUMA_NODE=3 + +sh ${ROCKETMQ_HOME}/bin/mqbroker $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqbroker.xml ---------------------------------------------------------------------- diff --git a/distribution/bin/mqbroker.xml b/distribution/bin/mqbroker.xml new file mode 100644 index 0000000..d1bc16f --- /dev/null +++ b/distribution/bin/mqbroker.xml @@ -0,0 +1,43 @@ +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + --> + +<java> + <debug>false</debug> + + <javahome>${JAVA_HOME}</javahome> + + <jvmtype>server</jvmtype> + + <mainclass>org.apache.rocketmq.broker.BrokerStartup</mainclass> + + <properties> + <java.ext.dirs>${cpd}/../lib</java.ext.dirs> + <rocketmq.home.dir>${cpd}/..</rocketmq.home.dir> + </properties> + + <classpaths> + </classpaths> + + <options> + <-Xms512m></-Xms512m> + <-Xmx1g></-Xmx1g> + <-XX:NewSize>256M</-XX:NewSize> + <-XX:MaxNewSize>512M</-XX:MaxNewSize> + <-XX:PermSize>128M</-XX:PermSize> + <-XX:MaxPermSize>128M</-XX:MaxPermSize> + </options> +</java> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqfiltersrv ---------------------------------------------------------------------- diff --git a/distribution/bin/mqfiltersrv b/distribution/bin/mqfiltersrv new file mode 100644 index 0000000..2fd0cbe --- /dev/null +++ b/distribution/bin/mqfiltersrv @@ -0,0 +1,45 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +if [ -z "$ROCKETMQ_HOME" ] ; then + ## resolve links - $0 may be a link to maven's home + PRG="$0" + + # need this for relative symlinks + while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG="`dirname "$PRG"`/$link" + fi + done + + saveddir=`pwd` + + ROCKETMQ_HOME=`dirname "$PRG"`/.. + + # make it fully qualified + ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` + + cd "$saveddir" +fi + +export ROCKETMQ_HOME + +sh ${ROCKETMQ_HOME}/bin/runserver.sh org.apache.rocketmq.filtersrv.FiltersrvStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqfiltersrv.cmd ---------------------------------------------------------------------- diff --git a/distribution/bin/mqfiltersrv.cmd b/distribution/bin/mqfiltersrv.cmd new file mode 100644 index 0000000..0503026 --- /dev/null +++ b/distribution/bin/mqfiltersrv.cmd @@ -0,0 +1,23 @@ +@echo off +rem Licensed to the Apache Software Foundation (ASF) under one or more +rem contributor license agreements. See the NOTICE file distributed with +rem this work for additional information regarding copyright ownership. +rem The ASF licenses this file to You under the Apache License, Version 2.0 +rem (the "License"); you may not use this file except in compliance with +rem the License. You may obtain a copy of the License at +rem +rem http://www.apache.org/licenses/LICENSE-2.0 +rem +rem Unless required by applicable law or agreed to in writing, software +rem distributed under the License is distributed on an "AS IS" BASIS, +rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +rem See the License for the specific language governing permissions and +rem limitations under the License. + +if not exist "%ROCKETMQ_HOME%\bin\runbroker.cmd" echo Please set the ROCKETMQ_HOME variable in your environment! & EXIT /B 1 + +call "%ROCKETMQ_HOME%\bin\runserver.cmd" org.apache.rocketmq.filtersrv.FiltersrvStartup %* + +IF %ERRORLEVEL% EQU 0 ( + ECHO "Filtersrv starts OK" +) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqfiltersrv.xml ---------------------------------------------------------------------- diff --git a/distribution/bin/mqfiltersrv.xml b/distribution/bin/mqfiltersrv.xml new file mode 100644 index 0000000..8fdea39 --- /dev/null +++ b/distribution/bin/mqfiltersrv.xml @@ -0,0 +1,43 @@ +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + --> + +<java> + <debug>false</debug> + + <javahome>${JAVA_HOME}</javahome> + + <jvmtype>server</jvmtype> + + <mainclass>org.apache.rocketmq.filtersrv.FiltersrvStartup</mainclass> + + <properties> + <java.ext.dirs>${cpd}/../lib</java.ext.dirs> + <rocketmq.home.dir>${cpd}/..</rocketmq.home.dir> + </properties> + + <classpaths> + </classpaths> + + <options> + <-Xms512m></-Xms512m> + <-Xmx1g></-Xmx1g> + <-XX:NewSize>256M</-XX:NewSize> + <-XX:MaxNewSize>512M</-XX:MaxNewSize> + <-XX:PermSize>128M</-XX:PermSize> + <-XX:MaxPermSize>128M</-XX:MaxPermSize> + </options> +</java> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e0d4a507/distribution/bin/mqnamesrv ---------------------------------------------------------------------- diff --git a/distribution/bin/mqnamesrv b/distribution/bin/mqnamesrv new file mode 100644 index 0000000..c1e70bd --- /dev/null +++ b/distribution/bin/mqnamesrv @@ -0,0 +1,45 @@ +#!/bin/sh + +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +if [ -z "$ROCKETMQ_HOME" ] ; then + ## resolve links - $0 may be a link to maven's home + PRG="$0" + + # need this for relative symlinks + while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG="`dirname "$PRG"`/$link" + fi + done + + saveddir=`pwd` + + ROCKETMQ_HOME=`dirname "$PRG"`/.. + + # make it fully qualified + ROCKETMQ_HOME=`cd "$ROCKETMQ_HOME" && pwd` + + cd "$saveddir" +fi + +export ROCKETMQ_HOME + +sh ${ROCKETMQ_HOME}/bin/runserver.sh org.apache.rocketmq.namesrv.NamesrvStartup $@
